package shuttle

  1. Overview
  2. Docs
val listen : ?max_connections:int -> ?max_accepts_per_batch:int -> ?backlog:int -> ?socket: ([ `Unconnected ], [< Async.Socket.Address.t ] as 'address) Async.Socket.t -> ?input_buffer_size:int -> ?output_buffer_size:int -> on_handler_error:[ `Call of 'address -> exn -> unit | `Ignore | `Raise ] -> f:('address -> Input_channel.t -> Output_channel.t -> unit Async.Deferred.t) -> ('address, 'listening_on) Async.Tcp.Where_to_listen.t -> ('address, 'listening_on) Async.Tcp.Server.t Async.Deferred.t
val with_connection : ?interrupt:unit Async.Deferred.t -> ?timeout:Core.Time.Span.t -> ?input_buffer_size:int -> ?output_buffer_size:int -> f:(Input_channel.t -> Output_channel.t -> 'res Async.Deferred.t) -> [< Async.Socket.Address.t ] Async.Tcp.Where_to_connect.t -> 'res Async_kernel__Types.Deferred.t
OCaml

Innovation. Community. Security.