Protocol_helpers (p.amqp-client-async.2.2.2.doc.amqp-client-async.Amqp_client_async.Protocol

Internal

Sourcemodule Protocol = Amqp_client_lib.Protocol

Sourcemodule Io = Amqp_client_lib.Io

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

Source

val write_method : 
  (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)) ->
  (Framing.t * Framing.channel_no) ->
  'c ->
  unit Thread.Deferred.t

Source

val 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)

Source

val 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

Source

val 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

Source

val reply0 : 
  ('a * (once:bool -> ('b -> unit) -> 'c -> 'd)) ->
  ?once:bool ->
  'c ->
  'b Async_kernel.Deferred.t

Source

val request1 : 
  ('a -> 'b -> unit Thread.Deferred.t) ->
  ('c * (once:bool -> ('d -> unit) -> 'a -> 'e)) ->
  'a ->
  'b ->
  'd Thread.Deferred.t

Source

val 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

Source

val 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