Connection.Unblocked
This method indicates that a connection has been unblocked and now accepts publishes.
val reply : ?once:bool -> (Framing.t * Framing.channel_no) -> unit Lwt.t
val request :
(Framing.t * Framing.channel_no) ->
unit ->
unit Thread.Deferred.t