responder

auto pull = NanoSocket(NanoSocket.Protocol.pull, BindTo("ipc://nanomsg_ipc_push_pull_test"));
auto push = NanoSocket(NanoSocket.Protocol.push, ConnectTo("ipc://nanomsg_ipc_push_pull_test"));

enum numTimes = 5;

foreach(i; 0 .. numTimes)
    push.send("foo");

foreach(i; 0 .. numTimes)
    pull.receive(No.blocking).shouldEqual("foo");