Is 0MQ completely done with the message(s) being tracked?

callback for showing that IOLoop is still responsive while we wait

Serialize object to JSON bytes (utf-8). Keyword arguments are passed along to :py:func:`json.dumps`.

Emit a log message on my socket.

encode raw bytes into Z85

Add printing event monitor to a zmq socket, it creates a thread by calling event_monitor_thread usage: event_monitor_async(socket) para

Add printing event monitor to a zmq socket, it creates a thread by calling event_monitor_thread_async See notes in description of : event_monitor

A thread that prints events This is a convenience method. It could serve as an example for your code of a monitor, For example if you don't n

A thread that prints events This is a convenience method. It could serve as an example for your code of a monitor, For example if you don't n

A pure-C function for DECREF'ing Python-owned message data. Sends a message on a PUSH socket The hint is a `zhint` struct with two values:

get context option see zmq_ctx_get

Get the High Water Mark. On libzmq ≥ 3, this gets SNDHWM if available, otherwise RCVHWM

Return a list of directories to include for linking against pyzmq with cython.

Return a list of directories used to link against pyzmq's bundled libzmq.

Get the value of a socket option. See the 0MQ documentation for details on specific options. Parameters ---------- o

Get context, based on call-time args

The RADIO-DISH group of the message. Requires libzmq >= 4.2 and pyzmq built with draft APIs enabled. .. versionadded:: 17

if heart is beating

Check for zmq capability by name (e.g. 'ipc', 'curve') .. versionadded:: libzmq-4.1 .. versionadded:: 14.1

Check for zmq capability by name (e.g. 'ipc', 'curve') .. versionadded:: libzmq-4.1 .. versionadded:: 14.1

generate `#ifndef ZMQ_CONST` block for zmq_constants.h

Check the exec path for include dirs.

DEPRECATED: No longer needed in pyzmq 17

DEPRECATED pyzmq 17 no longer needs any special integration for tornado.

set the tornado IOLoop instance with the pyzmq IOLoop. After calling this function, tornado's IOLoop.instance() and pyzmq's IOLoop.instance()

Fix CTRL-C on Windows using "self pipe trick".

Create tornado io_loop on current asyncio event loop

Join a RADIO-DISH group Only for DISH sockets. libzmq and pyzmq must have been built with ZMQ_BUILD_DRAFT_API .. v

Perform a latency test

echo messages on a REP socket Should be started before `latency`

Leave a RADIO-DISH group Only for DISH sockets. libzmq and pyzmq must have been built with ZMQ_BUILD_DRAFT_API ..

Load object from JSON bytes (utf-8). Keyword arguments are passed along to :py:func:`json.loads`.

Modify the flags for an already registered 0MQ socket or native fd.

s.monitor(addr, flags) Start publishing socket events on inproc. See libzmq docs for zmq_monitor for details. Note: requires

DEPRECATED, does nothing

Same as on_send, but callback will get this stream as first argument Callback will be passed three arguments:: callback(stream,

Create an ssh tunnel using command-line ssh that connects port lport on this machine to localhost:rport on server. The tunnel will automatica

launch a tunner with paramiko in a subprocess. This should only be used when shell ssh is unavailable (e.g. Windows). This creates a tunnel r

print dots to indicate idleness

poll the socket for events returns a Future for the poll results.

Overridden method to ensure that the green version of Poller is used. Behaves the same as :meth:`zmq.core.Poller.poll`

Poll the socket for events. See :class:`Poller` to wait for multiple sockets at once. Parameters ---------- timeout

Also grab context_name out of kwargs

Produce messages

Generate CONST: int for mypy

Start a zeromq proxy with control flow. .. versionadded:: libzmq-4.1 .. versionadded:: 18.0 Parameters ---------- frontend

proxy_steerable(frontend, backend, capture, control) Start a zeromq proxy with control flow. .. versionadded:: libzmq-4.1 .. versionadde

This function is automatically run by pytest passing all collected test functions. We use it to add asyncio marker to all async tests and asse

Use entirely high-level Python APIs to send messages

return the version of pyzmq as a string

return the pyzmq version as a tuple of at least three numbers If pyzmq is a development version, `inf` will be appended after the third integer.

receive messages with polling

Receive a single zmq frame. Returns a Future, whose result will be the received frame. Recommend using recv_multipart instead.

Receive a single zmq frame into a pre-allocated buffer. Returns a Future, whose result will be the number of bytes received.

Receive up to nbytes bytes from the socket, storing the data into a buffer rather than allocating a new Frame. The next mess

Receive a complete multipart zmq message. Returns a Future whose result will be a multipart message.

call recv_multipart in a way that raises if there is nothing to receive