Socket.receive

Receives a message frame.

_receive blocks until the request can be satisfied, and returns the number of bytes in the frame. tryReceive performs the operation in non-blocking mode, and returns a $(STDREF typecons,Tuple) which contains the size of the frame along with a bool value that signifies whether a frame was received. (If the latter is false, the former is always set to zero.)

size_t receive(ubyte[] data)
size_t receive(Frame msg)
struct Socket
@safe
size_t
receive
(
ref Frame msg
)
this(SocketType type)
this(Context context, SocketType type)

Throws

ZmqException if $(ZMQ) reports an error.

Corresponds to

$(ZMQREF zmq_msg_recv()) (with the ZMQ_DONTWAIT flag, in the case of tryReceive).

Examples

// Sender
auto snd = Socket(SocketType.req);
snd.connect("inproc://zmqd_msg_receive_example");
snd.send("Hello World!");

// Receiver
import std.string: representation;
auto rcv = Socket(SocketType.rep);
rcv.bind("inproc://zmqd_msg_receive_example");
auto msg = Frame();
rcv.receive(msg);
assert (msg.data.asString() == "Hello World!");

Socket.receive

Throws

Corresponds to

Examples

Meta

Source