Wrapper functions for backwards compatibility with rzmq. See vignette for examples.
send.socket(socket, data, send.more = FALSE, serialize = TRUE)receive.socket(socket, unserialize = TRUE, dont.wait = FALSE)
init.context()
init.socket(context, socket.type)
bind.socket(socket, address)
connect.socket(socket, address)
A ZMQ socket.
An R object.
Logical; will more messages be sent?
Logical; determines if serialize/unserialize should be called on the sent/received data.
Logical; determines if reception is blocking.
A ZMQ context.
The type of ZMQ socket as a string, of the form "ZMQ_type". Valid 'type' values are PAIR, PUB, SUB, REQ, REP, DEALER, PULL, PUSH, XPUB, XSUB, and STERAM.
A valid address. See details.
send.socket()
/receive.socket()
send/receive messages over
a socket. These are simple wrappers around zmq.msg.send()
and
zmq.msg.receive()
, respectively.
init.context()
creates a new ZeroMQ context. A useful wrapper
around zmq.ctx.new()
which handles freeing memory for you, i.e.
zmq.ctx.destroy()
will automatically be called for you.
init.socket()
creates a ZeroMQ socket; serves as a high-level
binding for zmq.socket()
, including handling freeing memory
automatically. See also .pbd_env$ZMQ.ST
.
bind.socket()
: see zmq.bind()
.
connect.socket()
: see zmq.connect()
ZeroMQ/4.1.0 API Reference: http://api.zeromq.org/4-1:_start
Programming with Big Data in R Website: http://r-pbd.org/