A Channel.t is a bi-directional communication channel for communicating to a Hub.t. Channels are portable across processes. A channel can be sent to another process, either explicitly or by being in a closure and it will continue to work.
val create :
?buffer_age_limit:[ `At_most of Core.Time.Span.t | `Unlimited ] ->
addr:(Async.Unix.Inet_addr.t * int) ->
unit ->
(_, _) t Async.Deferred.tcreate is type-unsafe, and should not be used by user code.
val close : (_, _) t -> unit Async.Deferred.tval read : (_, 'b) t -> 'b Async.Deferred.tval read_full : (_, 'b) t -> 'b Async.Reader.Read_result.t Async.Deferred.tval write : ('a, _) t -> 'a -> unitval pre_pack : 'a -> 'a pre_packedval write_pre_packed : ('a, _) t -> 'a pre_packed -> unitval flushed : (_, _) t -> unit Async.Deferred.tval socket : (_, _) t -> Async.Unix.Inet_addr.t * intval errors : (_, _) t -> exn Async.Stream.tSimilar to Monitor.detach_and_get_error_stream, collects all writer errors. If this function has never been called, then exceptions will be raised directly