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 : Hydro_transport.sockaddr
method getsockname : Hydro_transport.sockaddr
method inactivate : unit -> unit
method peer_user_name : string option
method read_eof : bool
method reading : bool
method set_timeout : notify:(unit -> unit) -> float -> unit
method skip_message : unit -> unit
method start_reading :
?peek:(unit -> unit) ->
?before_record:(int -> Hydro_transport.sockaddr -> unit) ->
when_done:((Hydro_types.msg_header * Netbuffer.t *
Hydro_transport.sockaddr)
Hydro_transport.result_eof -> unit) ->
unit -> unit
method start_shutting_down :
when_done:(unit Hydro_transport.result -> unit) -> unit -> unit
method start_writing :
when_done:(unit Hydro_transport.result -> unit) ->
Hydro_types.msg_buffer -> Hydro_transport.sockaddr -> unit
method start_writing_eof :
when_done:(unit Hydro_transport.result -> unit) -> unit -> unit
method transport_protocol_type : Hydro_types.transport_protocol_type
method writing : bool
end
