package async-zmq

  1. Overview
  2. Docs
package async-zmq
Legend:
Library
Module
Module type
Parameter
Class
Class type

This module 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

type 'a t

An Async-wrapped zeromq socket

include sig ... end
val sexp_of_t : ('a -> Sexplib.Sexp.t) -> 'a t -> Sexplib.Sexp.t
val of_socket : 'a ZMQ.Socket.t -> 'a t

of_socket s wraps the zeromq socket s for use with Async

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

to_socket s extracts the raw zeromq socket from s

val recv : 'a t -> string Async.Std.Deferred.t

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

val send : 'a t -> string -> unit Async.Std.Deferred.t

send socket sends a message on socket without blocking other Async threads

val recv_all : 'a t -> string list Async.Std.Deferred.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 Async.Std.Deferred.t

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

val close : 'a t -> unit Async.Std.Deferred.t