Module Make.Router
val recv : [ `Router ] t -> (id_t * string list) T.Deferred.t
recv socket
waits for a message onsocket
without blocking other Lwt threads.
val send : [ `Router ] t -> id_t -> string list -> unit T.Deferred.t
send socket id message
sendsmessage
onsocket
toid
without blocking other Lwt threads.