sig
type 'a result = [ `Error of exn | `Ok of 'a ]
type 'a result_eof = [ `End_of_file | `Error of exn | `Ok of 'a ]
type sockaddr = [ `Implied | `Sockaddr of Unix.sockaddr ]
class type hydro_multiplex_controller =
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
val stream_hydro_multiplex_controller :
?close_inactive_descr:bool ->
Unix.file_descr ->
Unixqueue.event_system -> Hydro_transport.hydro_multiplex_controller
val datagram_hydro_multiplex_controller :
?close_inactive_descr:bool ->
Unix.file_descr ->
Unixqueue.event_system -> Hydro_transport.hydro_multiplex_controller
class stream_hydro_multiplex_controller :
Hydro_transport.sockaddr ->
Hydro_transport.sockaddr ->
string option ->
Uq_engines.multiplex_controller ->
Unixqueue.event_system -> hydro_multiplex_controller
end
