Up

Module 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