Wrapper Functions for rzmq {pbdZMQ} | R Documentation |
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)
socket |
A ZMQ socket. |
data |
An R object. |
send.more |
Logical; will more messages be sent? |
serialize, unserialize |
Logical; determines if serialize/unserialize should be called on the sent/received data. |
dont.wait |
Logical; determines if reception is blocking. |
context |
A ZMQ context. |
socket.type |
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. |
address |
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()
Wei-Chen Chen wccsnow@gmail.com.
ZeroMQ/4.1.0 API Reference: http://api.zeromq.org/4-1:_start
Programming with Big Data in R Website: http://r-pbd.org/