val udp_server :
addr:string ->
port:int ->
f:(Async.Socket.Address.Inet.t -> string -> unit Async.Deferred.t) ->
unit Async.Deferred.tudp_server addr port f except that f is called on every packet received with the address it was received from and the data received. The next packet will not be read until the Deferred returned by f is determined
val udp_client :
addr:string ->
port:int ->
f:(Async.Writer.t -> 'a Async.Deferred.t) ->
'a Async.Deferred.tudp_client ~addr ~port ~f Same as tcp_client for udp
val connect :
[< `Inet of Async.Unix.Inet_addr.t * int | `Unix of string ] as 'a
Async.Socket.Type.t ->
addr:'a ->
([ `Active ], 'a) Async.Socket.t Async.Deferred.tconnect socket_type ~addr connects a socket to addr
val tcp_server_generic :
?max_connections:int ->
addr:'a ->
stype:'a Async.Socket.Type.t ->
on_client_error:[ `Ignore | `Call of 'a -> exn -> unit ] ->
f:('a -> Async.Reader.t -> Async.Writer.t -> unit Async.Deferred.t) ->
?buffer_age_limit:[ `At_most of Core.Time.Span.t | `Unlimited ] ->
unit ->
unit Async.Deferred.tval tcp_server_unix :
?max_connections:int ->
addr:Async.Socket.Address.Unix.t ->
on_client_error:
[ `Ignore | `Call of Async.Socket.Address.Unix.t -> exn -> unit ] ->
f:
(Async.Socket.Address.Unix.t ->
Async.Reader.t ->
Async.Writer.t ->
unit Async.Deferred.t) ->
?buffer_age_limit:[ `At_most of Core.Time.Span.t | `Unlimited ] ->
unit ->
unit Async.Deferred.ttcp_server_unix ~addr ~port ?on_client_error ~f makes a tcp server over a unix domain socket, listening on a path indicated by addr. When clients connect f will be run and is passed the address of the client, and a Reader and Writer for communicating with the client. When the deferred returned by f is determined or f throws an exception the client socket and the reader and writer will be closed. The Deferred returned by the function as a whole will be determined when the server is ready to accept incoming connections