Up

Module Transport

Signature

type t

val create : Async_extra.Import.Reader.t -> Async_extra.Import.Writer.t -> t Async_extra.Import.Deferred.t

val close : t -> unit Async_extra.Import.Deferred.t

val read : t -> [

| `Eof

| `Ok of Client_message.t

] Async_extra.Import.Deferred.t

val write : t -> Server_message.t -> unit

val flushed_time : t -> Core.Std.Time.t Async_extra.Import.Deferred.t