Add a recv event, returning the corresponding Future

Deserialize a received message Override in subclass (e.g. Futures) if recvd is not the raw bytes. The default implementation expects

Schedule a call to handle_events next loop iteration If there are still events to handle.

Make an API request

call recv[_multipart] in a way that raises if there is nothing to receive

Run Ironhouse example

Enqueue setsockopt(opt, value) for in_socket See zmq.Socket.setsockopt for details.

Add a send event, returning the corresponding Future

Schedule a function to be called later Override for different IOLoop implementations Tornado and asyncio happen to both have ioloop.

Wrap running callbacks in try/except to allow us to close our socket.

setsockopt, retrying interrupted calls checks rc, raising ZMQError on failure.

Update IOLoop handler with state.

wait for zmq garbage collection Necessary because of the zero-copy gc thread, which can take some time to receive its DECREF message.

Enqueue a random port on the given interface for binding on ctrl_socket. See zmq.Socket.bind_to_random_port for details.

A memoryview of the message contents.

Cast an address to a Python int This could be a Python integer or a CFFI pointer

Close this stream.

Enqueue ZMQ address for connecting on in_socket. See zmq.Socket.connect for details.

Enqueue ZMQ address for connecting on out_socket. See zmq.Socket.connect for details.

Deny IP address(es). Addresses not explicitly denied will be allowed to continue with authentication. deny is mutually exclusive wit

Shutdown the PAIR socket (created using get_monitor_socket) that is serving socket events. .. versionadded:: 14.4

Get the value of a context option. See the 0MQ API documentation for zmq_ctx_get for details on specific options. .

Returns a global `IOLoop` instance. Most applications have a single, global `IOLoop` running on the main thread. Use this method to

Start publishing socket events on inproc. See libzmq docs for zmq_monitor for details. While this function is available from

Select the pyzmq backend

Send a message, optionally also register a new callback for sends. See zmq.socket.send for details.

stop the garbage-collection thread

version tuple as string

Add io_state to poller.

Add io_state to poller.

Add a timeout for a send or recv Future

Clear state called after stop or when setting up a new subprocess

unregister the ioloop event handler called once during close

Copy the data from a zmq_msg_t

Stop poller from watching an io_state.

Handle recv events

Handle a recv event.

Handle a send event.

translate IOLoop.READ/WRITE/ERROR event masks into zmq.POLLIN/OUT/ERR

rebuild io state based on self.sending() and receiving()

call recv[_multipart] in a way that raises if there is nothing to receive

call recv[_multipart] in a way that raises if there is nothing to receive

Send a message on this socket by copying its content.

Send a copy of a bufferable

Update IOLoop handler with state. zmq FD is always read-only.

Create a certificate file

Enqueue ZMQ address for binding on in_socket. See zmq.Socket.bind for details.

Configure PLAIN authentication for a given domain. PLAIN authentication uses a plain-text password file. To cover all domains, use "*

Do a single run

Fast shallow copy of the Frame. Does not copy underlying data.

check setup.cfg, then /usr/local/include, then /usr/include for zmq.h. Then scrape zmq.h for the version tuple. Returns ------- (

Create an async socket from an existing Socket

generate a constants file from its template

Perform ZAP authentication

does the given constant have a ZMQ_ prefix?

decode zmq_monitor event messages. Parameters ---------- msg : list(bytes) zmq multipart message that has arrived on a monitor PA

Return a Future for a poll event

poll in seconds rather than milliseconds. Event masks will be IOLoop.READ/WRITE/ERROR

Process args passed to the decorator. args not consumed by the decorator will be passed to the target factory (Context/Socket constru

Start a zeromq proxy (replacement for device). .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 Parameters ---------- fr

Returns True if we are currently receiving from the stream.

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

recv a numpy array

reconstruct a Python object sent with zipped_pickle

Run mypy for a path Captures output and reports it on errors

Select and return n random ports that are available.

Send a multipart message, optionally also register a new callback for sends. See zmq.socket.send_multipart for details.

pack and compress an object with pickle and zlib.