Transport (u.2e860148a0a2ed8bc39c501c5fb966f4.async.v0.15.0.doc.async.async_rpc.Async

module Async_reader := Async_unix.Reader

module Async_writer := Async_unix.Writer

module Reader : sig ... end

module Writer : sig ... end

include module type of struct include Async_rpc_kernel.Rpc.Transport end
  with module Reader := Async_rpc_kernel.Rpc.Transport.Reader
  with module Writer := Async_rpc_kernel.Rpc.Transport.Writer

module Header = Async_rpc_kernel.Rpc.Transport.Header

Binary headers containing message lengths. All transports should use this to ensure binary compatibility.

module Handler_result = Async_rpc_kernel.Rpc.Transport.Handler_result

module Send_result = Async_rpc_kernel.Rpc.Transport.Send_result

type t = {

reader : Async_rpc_kernel.Rpc.Transport.Reader.t;
writer : Async_rpc_kernel.Rpc.Transport.Writer.t;

}

val sexp_of_t : t -> Sexplib0.Sexp.t

val close : t -> unit Async_kernel.Deferred.t

Closes both parts of the transport.

val of_reader_writer : 
  ?max_message_size:int ->
  Async_reader.t ->
  Async_writer.t ->
  t

val of_fd : 
  ?buffer_age_limit:Async_writer.buffer_age_limit ->
  ?reader_buffer_size:int ->
  max_message_size:int ->
  Async_unix.Fd.t ->
  t

module Tcp : sig ... end