package amqp-client-lwt

  1. Overview
  2. Docs
Amqp client library, lwt version

Install 

dune-project
 Dependency

github.com Readme Edit opam file Versions (6)

Authors

  1. A
    Anders Fugmann

Maintainers

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

Sources

2.3.0.tar.gz
md5=9db83accd0dfa9231c3f2ca0de9c8d9f
sha512=921c3f4d0d655dc5caa5c89fe8c4309a6e22d91167676062e0e73f3007b0b5de20e7b461aefdddca6dbdf716d57d90eaefb7e974ae218cce0f0a20fb461c965d

doc/amqp-client-lwt/Amqp_client_lwt/Protocol_helpers/index.html

Module Amqp_client_lwt.Protocol_helpersSource

Internal

Sourcetype 'a post_handler = ('a -> unit) option
Sourceval bit_string : int -> int -> string
Sourceval update_property_flag : int -> (int -> 'a) -> int -> 'a
Sourceval read_property_flag : int -> int -> int
Sourceval list_create : (unit -> 'a) -> int -> 'a list
Sourceval read_method : (Amqp_client_lib.Types.message_id * ('b, 'a) Protocol.Spec.spec * 'b * 'c) -> Amqp_client_lib.Types.message_id * (once:bool -> ('a -> unit) -> (Framing.t * Framing.channel_no) -> unit)
Sourceval write_method_content : (Amqp_client_lib.Types.message_id * ('a, Amqp_client_lib.Io.Output.t) Protocol.Spec.spec * 'b * ('a -> 'c -> Amqp_client_lib.Io.Output.t)) -> ((Amqp_client_lib.Types.class_id * 'd) * ('e, Amqp_client_lib.Io.Output.t) Protocol.Content.spec * 'f * ('e -> 'g -> Amqp_client_lib.Io.Output.t)) -> (Framing.t * Framing.channel_no) -> ('c * 'g * string) -> unit Thread.Deferred.t
Sourceval read_method_content : (Amqp_client_lib.Types.message_id * ('a, 'b) Protocol.Spec.spec * 'a * 'c) -> ((Amqp_client_lib.Types.class_id * 'd) * ('e, 'f) Protocol.Content.spec * 'e * 'g) -> Amqp_client_lib.Types.message_id * (once:bool -> (('b * ('f * string)) -> unit) -> (Framing.t * Framing.channel_no) -> unit)
Sourceval request0 : ('a -> 'b -> 'c) -> 'a -> 'b -> 'c
Sourceval reply0 : ('a * (once:bool -> ('b -> unit) -> 'c -> 'd)) -> ?once:bool -> 'c -> 'b Lwt.t
Sourceval request1 : ('a -> 'b -> unit Thread.Deferred.t) -> ('c * (once:bool -> ('d -> unit) -> 'a -> 'e)) -> 'a -> 'b -> 'd Thread.Deferred.t
Sourceval reply1 : ('a * (once:bool -> ('b -> unit) -> 'c -> 'd)) -> ('c -> 'e -> 'f Thread.Deferred.t) -> ?once:bool -> 'c -> ('b -> 'e Thread.Deferred.t) -> 'f Thread.Deferred.t
Sourceval request2 : ((Framing.t * Framing.channel_no) -> 'a -> unit Thread.Deferred.t) -> (Amqp_client_lib.Types.message_id * (once:bool -> ('b -> unit) -> (Framing.t * Framing.channel_no) -> 'c)) -> ('b -> 'd) -> (Amqp_client_lib.Types.message_id * (once:bool -> ('e -> unit) -> (Framing.t * Framing.channel_no) -> 'f)) -> ('e -> 'd) -> (Framing.t * Framing.channel_no) -> 'a -> 'd Thread.Deferred.t