Up
Module
Udp
=
Udp
Signature
val
udp_server : addr:string -> port:int -> f:(
Async.Std.Socket.Address.Inet.t
-> string -> unit
Async.Std.Deferred.t
) -> unit
Async.Std.Deferred.t
val
udp_client : addr:string -> port:int -> f:(
Async.Std.Writer.t
-> 'a
Async.Std.Deferred.t
) -> 'a
Async.Std.Deferred.t
val
connect : ([<
| `Inet
of
Async.Std.Unix.Inet_addr.t
* int &
Async_unix.Unix_syscalls.Inet_addr.t
* int &
Async_unix.Unix_syscalls.Inet_addr.t
* int &
Async_unix.Unix_syscalls.Inet_addr.t
* int &
Async_unix.Unix_syscalls.Inet_addr.t
* int
| `Unix
of
string & string & string & string & string
]
as
'a)
Async.Std.Socket.Type.t
-> addr:'a -> ([
| `Active
], 'a)
Async.Std.Socket.t
Async.Std.Deferred.t
val
tcp_server_generic : ?max_connections:int -> addr: ([<
| `Inet
of
Async_unix.Unix_syscalls.Inet_addr.t
* int &
Async_unix.Unix_syscalls.Inet_addr.t
* int
| `Unix
of
string & string
]
as
'a) -> stype:'a
Async.Std.Socket.Type.t
-> on_client_error:[
| `Call
of
'a -> exn -> unit
| `Ignore
] -> f:('a ->
Async.Std.Reader.t
->
Async.Std.Writer.t
-> unit
Async.Std.Deferred.t
) -> ?buffer_age_limit:[
| `At_most
of
Core.Std.Time.Span.t
| `Unlimited
] -> unit -> unit
Async.Std.Deferred.t
val
tcp_server_unix : ?max_connections:int -> addr:
Async.Std.Socket.Address.Unix.t
-> on_client_error:[
| `Call
of
Async.Std.Socket.Address.Unix.t
-> exn -> unit
| `Ignore
] -> f:(
Async.Std.Socket.Address.Unix.t
->
Async.Std.Reader.t
->
Async.Std.Writer.t
-> unit
Async.Std.Deferred.t
) -> ?buffer_age_limit:[
| `At_most
of
Core.Std.Time.Span.t
| `Unlimited
] -> unit -> unit
Async.Std.Deferred.t