package zmq

  1. Overview
  2. Docs
OCaml bindings for ZeroMQ 4.x

Install 

dune-project
 Dependency

github.com Readme Changelog MIT License Edit opam file Versions (11)

Authors

  1. A
    Anders Fugmann
  2. P
    Pedro Borges
  3. P
    Peter Zotov

Maintainers

  1. A
    Anders Fugmann <anders@fugmann.net>

Sources

zmq-5.3.0.tbz
sha256=b5eb42995836eff58767e1ccc0a6551c2ac74f358094ac2402334389b075fba8
sha512=712eac902ea9c52ac0b47c80a851ee29ca3ea5a69a16ecac2b1ba5c0ff83082a41524e41fdbdeddc7a1c3037e5a4d1494a17ebf7c0b202603f652edab5a1aee7

doc/zmq.deferred/Zmq_deferred/Socket/Make/index.html

Module Socket.MakeSource

Parameters

module T : Deferred.T

Signature

Sourcetype 'a deferred = 'a T.t
Sourcetype 'a t

An concurrent zeromq socket

Sourcetype 'a of_socket_args = 'a
Sourceval of_socket : ('a Zmq.Socket.t -> 'a t) of_socket_args

of_socket s wraps the zeromq socket s

Sourceval to_socket : 'a t -> 'a Zmq.Socket.t

to_socket s extracts the raw zeromq socket from s

Sourceval recv : 'a t -> string deferred

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

Sourceval send : 'a t -> string -> unit deferred

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

Sourceval recv_all : 'a t -> string list deferred

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

Sourceval send_all : 'a t -> string list -> unit deferred

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

Sourceval recv_msg : 'a t -> Zmq.Msg.t deferred

recv_msg socket waits for a message on socket without blocking other concurrent threads

Sourceval send_msg : 'a t -> Zmq.Msg.t -> unit deferred

send_msg socket sends a message on socket without blocking other concurrent threads

Sourceval recv_msg_all : 'a t -> Zmq.Msg.t list deferred

recv_msg_all socket waits for a multi-part message on socket without blocking other concurrent threads

Sourceval send_msg_all : 'a t -> Zmq.Msg.t list -> unit deferred

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

Sourceval close : 'a t -> unit deferred
Sourcemodule Router : sig ... end
Sourcemodule Monitor : sig ... end