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

Options for Socket.get/set .. versionadded:: 23

Run ZAP authentication in a background thread

Socket monitoring events .. versionadded:: 23

ZAP authentication for use in the asyncio IO loop

Wrapper for zmq.EAGAIN .. versionadded:: 13.0

Wrapper for zmq.ETERM .. versionadded:: 13.0

ZAP authentication for use in the tornado IOLoop

Wrapper for EINTR This exception should be caught internally in pyzmq to retry system calls, and not propagate to the user. .. versionad

Poller returning asyncio.Future for poll results.

An error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port

Context Manager for socket bind/unbind

Utility for fixing CTRL-C events on Windows. On Windows, the Python interpreter intercepts CTRL-C events in order to translate them into ``Ke

A Thread for running a zmq Authenticator This is run in the background by ThreadAuthenticator

Create a zmq Context A zmq Context creates sockets via its ``ctx.socket`` method. .. versionchanged:: 24 When using a Context as a

PyZMQ Garbage Collector Used for representing the reference held by libzmq during zero-copy sends. This object holds a dictionary, keyed by P

Thread in which garbage collection actually happens.

A basic HeartBeater class pingstream: a PUB stream pongstream: an ROUTER stream

A class for tracking if 0MQ is done using one or more messages. When you send a 0MQ message, it is not sent immediately. The 0MQ IO thread se

ZMQ server that adds/fetches documents (ie dictionaries) to a MongoDB. NOTE: mongod must be started before using this class

Client that connects with MongoZMQ server to add/fetch docs

A basic logging handler that emits log messages through a PUB socket. Takes a PUB socket already bound to interfaces or an interface to bind to.

A stateful poll interface that mirrors Python's built-in poll.

zmq socket types .. versionadded:: 23

Raised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2

Decorator subclass for Contexts

Decorator subclass for sockets Gets the context from other args.

Implementation of ZAP authentication for zmq connections. This authenticator class does not register with an event loop. As a result, you wil

Base class for launching Devices in background processes and threads.

Context for creating asyncio-compatible Sockets

Manage the lifecycle of a 0MQ context. Parameters ---------- io_threads : int The number of IO threads.

Options for Context.get/set .. versionadded:: 23

Schedules the given callback to be called once. The callback is called once, after callback_time milliseconds. `start` must be called after

A 0MQ Device to be run in the background. You do not pass Socket instances to this, but rather Socket types:: Device(device_type, in_soc

Device type constants for zmq.device .. versionadded: 23

Warning for using experimental FD on draft sockets. .. versionadded:: 27

libzmq error codes .. versionadded:: 23

Send/recv flags .. versionadded:: 23

A zmq message Frame class for non-copying send/recvs and access to message properties. A ``zmq.Frame`` wraps an underlying ``zmq_msg_t``.

Mixin for making green versions of test classes

Mixin for making green versions of test classes

Options on zmq.Frame objects .. versionadded:: 23

Class for running monitored_queue in the background. See zmq.devices.Device for most of the spec. MonitoredQueue differs from Proxy, only in

Base class for overriding methods.

Values for zmq.NORM_MODE socket option .. versionadded:: 26 .. versionadded:: libzmq-4.3.5 (draft)

Raised when timeout is reached while waiting for 0MQ to finish with a Message See Also -------- .MessageTracker.wait : object for trackin

Which events to poll for in poll methods .. versionadded: 23

Warning class for notifying about the extra thread spawned by tornado We automatically support proactor via tornado's AddThreadSelectorEventLoop

A Device that will be run in a background Process. See Device for details.

Run zmq.monitored_queue in a separate process. See MonitoredQueue and Proxy for details.

Proxy in a Process. See Proxy for more.

ProxySteerable in a Process. See ProxySteerable for details.

Threadsafe Proxy object. See zmq.devices.Device for most of the spec. This subclass adds a <method>_mon version of each <method>_{in|out} met

Base class for overriding methods.

Class for running a steerable proxy in the background. See zmq.devices.Proxy for most of the spec. If the control socket is not NULL, the pr

Base class for overriding methods.

Select behavior for socket.reconnect_stop .. versionadded:: 25

Values for zmq.ROUTER_NOTIFY socket option .. versionadded:: 26 .. versionadded:: libzmq-4.3.0 (draft)

Security mechanisms (as returned by ``socket.get(zmq.MECHANISM)``) .. versionadded:: 23

A class with some extra serialization methods send_zipped_pickle is just like send_pyobj, but uses zlib to compress the stream before sending

Socket returning asyncio Futures for send/recv/poll methods.

A 0MQ socket. These objects will generally be constructed via the socket() method of a Context object. Note: 0MQ Sockets are *not* thre

The ZMQ socket object To create a Socket, first create a Context:: ctx = zmq.Context.instance() then call ``ctx.socket(socket_type)