package zmq
Install
Dune Dependency
Authors
Maintainers
Sources
sha256=13b74e6a50f56485ef0d563a2d2275c53d2f5b51d638f204412df794a66dff61
sha512=a47a6def598c1d514a86dbe0918aeb7d8f04da9af7456f4654f77717264c403d784b99552a7dd5f0e4597c5df01dbe16e8db9a47b41bd3f408efc4cb5a93874a
doc/zmq.deferred/Zmq_deferred/Socket/Make/index.html
Module Socket.Make
Source
This functor is meant to be as compatible as possible with lwt-zmq. It should be straight forward to write a functor over Async_zmq.Socket and Lwt_zmq.Socket.
The functor allows abstraction of the concurrency monad
Parameters
module T : Deferred.T
Signature
An concurrent zeromq socket
of_socket s
wraps the zeromq socket s
to_socket s
extracts the raw zeromq socket from s
recv socket
waits for a message on socket
without blocking other concurrent threads
send socket
sends a message on socket
without blocking other concurrent threads
recv_all socket
waits for a multi-part message on socket
without blocking other concurrent threads
send_all socket m
sends all parts of the multi-part message m
on socket
without blocking other concurrent threads
recv_msg socket
waits for a message on socket
without blocking other concurrent threads
send_msg socket
sends a message on socket
without blocking other concurrent threads
recv_msg_all socket
waits for a multi-part message on socket
without blocking other concurrent threads
send_msg_all socket m
sends all parts of the multi-part message m
on socket
without blocking other concurrent threads