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-lwt-5.1.4.tbz
sha256=7e39ff4f4930e5c4fcb66235de54a2b8ebdb2d3efbd3f44c6f3b61fd07b8e8ed
sha512=c086989220a831359707e8be04a9fcc5817d3145e5da89bb9210ed3619611ed47b0cedb7d3c2319d6e2fc5ca0f48aa2e46bde72b0bee824594a019c6dcc624c0

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

Module Socket.MakeSource

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

Sourcetype 'a t

An concurrent zeromq socket

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

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 to_string_hum : 'a t -> string

Internal statisitcs of the socket

Sourceval recv : 'a t -> string T.Deferred.t

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

Sourceval send : 'a t -> string -> unit T.Deferred.t

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

Sourceval recv_all : 'a t -> string list T.Deferred.t

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

Sourceval send_all : 'a t -> string list -> unit T.Deferred.t

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 T.Deferred.t

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

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

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

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

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 T.Deferred.t

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 T.Deferred.t
Sourcemodule Router : sig ... end
Sourcemodule Monitor : sig ... end