package amqp-client-async

  1. Overview
  2. Docs

Module Amqp_client_async.ThreadSource

include Amqp_client_lib.Thread.T with type 'a Deferred.t = 'a Async_kernel.Deferred.t and type Writer.t = Async.Writer.t and type Reader.t = Async.Reader.t and type 'a Pipe.Reader.t = 'a Async.Pipe.Reader.t and type 'a Pipe.Writer.t = 'a Async.Pipe.Writer.t and type 'a Ivar.t = 'a Async_kernel.Ivar.t
Sourcemodule Deferred : sig ... end
Sourceval (>>=) : 'a Deferred.t -> ('a -> 'b Deferred.t) -> 'b Deferred.t
Sourceval (>>|) : 'a Deferred.t -> ('a -> 'b) -> 'b Deferred.t
Sourceval return : 'a -> 'a Deferred.t
Sourceval after : float -> unit Deferred.t
Sourceval spawn : ?exn_handler:(exn -> unit Deferred.t) -> unit Deferred.t -> unit
Sourceval with_timeout : int -> 'a Deferred.t -> [ `Result of 'a | `Timeout ] Deferred.t
Sourcemodule Ivar : sig ... end
Sourcemodule Reader : sig ... end
Sourcemodule Writer : sig ... end
Sourcemodule Tcp : sig ... end
Sourcemodule Log : sig ... end
Sourcemodule Pipe : sig ... end
Sourcemodule Scheduler : sig ... end
OCaml

Innovation. Community. Security.