The main logic of decorator Here is how those arguments works:: @out_decorator(*dec_args, *dec_kwargs) def

Create a shallow copy of the message. This does not copy the contents of the Frame, just the pointer. This will increment the 0MQ ref

Copying a Context creates a shadow copy

Copying a Socket creates a shadow copy

Deleting a Context without closing it destroys it and all sockets. .. versionchanged:: 24 Switch from threadsafe `term()` which h

delete default sockopts as attributes

Install the custom CTRL-C handler.

Sockets are context managers .. versionadded:: 14.4

Remove the custom CTRL-C handler.

get zmq options by attribute

Wrap an errno style error. Parameters ---------- errno : int The ZMQ errno or None. If None, then ``zmq_errno()`

Translate ``action`` into a CTRL-C handler. ``action`` is a callable that takes no arguments and returns no value (returned value is

Create a message tracker to track a set of messages. Parameters ---------- *towatch : tuple of Event, MessageTracker, Message

bind_addr: address to bind zmq socket on db_name: name of database to write to (created if doesn't exist) table_name: name of

Return the length of the message in bytes.

Attach option type as `._opt_type`

Return the str form of the message.

Override to allow setting zmq.[UN]SUBSCRIBE even though we have a subscribe method

set zmq options by attribute

pytest doesn't support async setup/teardown