zmqd v0.1.0-alpha1 (2013-12-22T12:23:30Z)

Socket.receive

zmqd Socket

Receives a message part.

_receive blocks until the request can be satisfied. tryReceive performs the operation in non-blocking mode, and returns a bool value that signifies whether a message was received.

  1. size_t receive(ubyte[] data)
    struct Socket
    @safe
    size_t
    receive
    (
    ubyte[] data
    )
  2. size_t receive(Message msg)
  3. this(SocketType type)
  4. this(Context context, SocketType type)

Throws

ZmqException if $(ZMQ) reports an error.

Corresponds to

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

Examples

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

// Receiver
import std.string: representation;
auto rcv = Socket(SocketType.rep);
rcv.bind("ipc://zmqd_receive_example");
char[256] buf;
immutable len  = rcv.receive(buf.representation);
assert (buf[0 .. len] == "Hello World!");

Meta

Source

See Implementation

zmqd Socket aliasesconstructorsfunctionsproperties

Page generated by adrdox