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 ]
exception Error of string
class type rpc_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 : 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 skip_message : unit -> unit
method start_reading :
?peek:(unit -> unit) ->
?before_record:(int -> Rpc_transport.sockaddr -> unit) ->
when_done:((Rpc_packer.packed_value * 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
val stream_rpc_multiplex_controller :
?close_inactive_descr:bool ->
Unix.file_descr ->
Unixqueue.event_system -> Rpc_transport.rpc_multiplex_controller
val datagram_rpc_multiplex_controller :
?close_inactive_descr:bool ->
Unix.file_descr ->
Unixqueue.event_system -> Rpc_transport.rpc_multiplex_controller
class stream_rpc_multiplex_controller :
Rpc_transport.sockaddr ->
Rpc_transport.sockaddr ->
string option ->
Uq_engines.multiplex_controller ->
Unixqueue.event_system -> rpc_multiplex_controller
end