Module Amqp_client_async.Thread

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
module Deferred : sig ... end with type 'a t = 'a Async_kernel.Deferred.t
val (>>=) : 'a Deferred.t -> ('a -> 'b Deferred.t) -> 'b Deferred.t
val (>>|) : 'a Deferred.t -> ('a -> 'b) -> 'b Deferred.t
val return : 'a -> 'a Deferred.t
val after : float -> unit Deferred.t
val spawn : ?⁠exn_handler:(exn -> unit Deferred.t) -> unit Deferred.t -> unit
val with_timeout : int -> 'a Deferred.t -> [ `Result of 'a | `Timeout ] Deferred.t
module Ivar : sig ... end with type 'a t = 'a Async_kernel.Ivar.t
module Reader : sig ... end with type t = Async.Reader.t
module Writer : sig ... end with type t = Async.Writer.t
module Tcp : sig ... end
module Log : sig ... end
module Pipe : sig ... end with type 'a Reader.t = 'a Async.Pipe.Reader.t and type 'a Writer.t = 'a Async.Pipe.Writer.t
module Scheduler : sig ... end