42 int rc =
zmq_bind (scatter,
"inproc://test-scatter-gather");
45 rc =
zmq_connect (gather,
"inproc://test-scatter-gather");
48 rc =
zmq_connect (gather2,
"inproc://test-scatter-gather");
55 rc =
s_send (scatter,
"1");
58 rc =
s_send (scatter,
"2");
61 char* message =
s_recv (gather);
63 assert (
streq(message,
"1"));
66 message =
s_recv (gather2);
68 assert (
streq(message,
"2"));
int s_sendmore(void *socket, const char *string)
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
char * s_recv(void *socket)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)
int s_send(void *socket, const char *string)