package lwt-zmq

You can search for identifiers within the package.

in-package search v0.2.0

Legend:
Library
Module
Module type
Parameter
Class
Class type

type 'a t

An Lwt-wrapped zeromq socket

val of_socket : 'a ZMQ.Socket.t -> 'a t

of_socket s wraps the zeromq socket s for use with Lwt

val to_socket : 'a t -> 'a ZMQ.Socket.t

to_socket s extracts the raw zeromq socket from s

val recv : 'a t -> string Lwt.t

recv socket waits for a message on socket without blocking other Lwt threads

val send : ?more:bool -> 'a t -> string -> unit Lwt.t

send ?more socket m sends a message m on socket without blocking other Lwt threads

val recv_all : 'a t -> string list Lwt.t

recv_all socket waits for a multi-part message on socket without blocking other Lwt threads

val send_all : 'a t -> string list -> unit Lwt.t

send_all socket m sends all parts of the multi-part message m on socket without blocking other Lwt threads

module Router : sig ... end