Poll functions
zmq.poll(socket, type, timeout = -1L, MC = ZMQ.MC())zmq.poll.free()
zmq.poll.length()
zmq.poll.get.revents(index = 1L)
zmq.poll()
returns a ZMQ code and an errno,
see ZeroMQ manual for details, no error/warning/interrupt in this
R
function, but some error/warning/interrupt may catch by
the C
function zmq_poll()
.
zmq.poll.length()
returns the total number of poll items
zmq.poll.get.revents()
returns the revent type
a vector of ZMQ sockets
a vector of socket types corresponding to socket
argument
timeout for poll, see ZeroMQ manual for details
a message control, see ZMQ.MC()
for details
an index of ZMQ poll items to obtain revents
Wei-Chen Chen wccsnow@gmail.com.
zmq.poll()
initials ZMQ poll items given ZMQ socket
's
and ZMQ poll type
's. Both socket
and type
are
in vectors of the same length, while socket
contains socket pointers
and type
contains types of poll.
See ZMQ.PO()
for the possible values of
type
. ZMQ defines several poll types and utilize
them to poll multiple sockets.
zmq.poll.free()
frees ZMQ poll structure memory internally.
zmq.poll.length()
obtains total numbers of ZMQ poll items.
zmq.poll.get.revents()
obtains revent types from ZMQ poll item by
the input index.
ZeroMQ/4.1.0 API Reference: https://libzmq.readthedocs.io/en/zeromq4-1/
Programming with Big Data in R Website: https://pbdr.org/
zmq.recv()
, zmq.send()
.