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)
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()
Programming with Big Data in R Website: