Thread (amqp-client-async.Amqp_client

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

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

module Reader : sig ... end

module Writer : sig ... end

module Tcp : sig ... end

module Log : sig ... end

module Pipe : sig ... end

module Scheduler : sig ... end