sig
type listen_address =
[ `Socket of Uq_engines.sockspec * Uq_server.listen_options
| `W32_pipe of
Netsys_win32.pipe_mode * string * Uq_server.listen_options ]
and listen_options =
Uq_engines.listen_options = {
lstn_backlog : int;
lstn_reuseaddr : bool;
}
val default_listen_options : Uq_server.listen_options
class type server_endpoint_acceptor =
object
method accept :
unit ->
(Unix.file_descr * Uq_engines.inetspec option) Uq_engines.engine
method multiple_connections : bool
method server_address : Uq_engines.connect_address
method shut_down : unit -> unit
end
class direct_acceptor :
?close_on_shutdown:bool ->
?preclose:(unit -> unit) ->
Unix.file_descr -> Unixqueue.event_system -> server_endpoint_acceptor
val listener :
?proxy:#Uq_engines.server_endpoint_listener ->
Uq_server.listen_address ->
Unixqueue.event_system ->
Uq_server.server_endpoint_acceptor Uq_engines.engine
end
