Thread (amqp-client-lwt.Amqp_client

include Amqp_client_lib.Thread.T with type 'a Deferred.t = 'a Lwt.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