`object
method abort_rw : unit -> unit
method alive : bool
method cancel_rd_polling : unit -> unit
method cancel_shutting_down : unit -> unit
method event_system : Unixqueue.event_system
method getpeername : Rpc_transport.sockaddr
method getsockname : Rpc_transport.sockaddr
method inactivate : unit -> unit
method peer_user_name : string option
method protocol : Rpc.protocol
method read_eof : bool
method reading : bool
method set_timeout : notify:(unit -> unit) -> float -> unit
method start_reading :
?peek:(unit -> unit) ->
?before_record:(int -> Rpc_transport.sockaddr -> Rpc_transport.in_rule) ->
when_done:((Rpc_transport.in_record * Rpc_transport.sockaddr)
Rpc_transport.result_eof -> unit) ->
unit -> unit
method start_shutting_down :
when_done:(unit Rpc_transport.result -> unit) -> unit -> unit
method start_writing :
when_done:(unit Rpc_transport.result -> unit) ->
Rpc_packer.packed_value -> Rpc_transport.sockaddr -> unit
method writing : bool
end`