Sourcetype flow = Lwt_unix.file_descr Sourcetype error = [ | `Refused| `Timeout| `Error of Unix.error * string * string
] Sourcetype write_error = [ | `Refused| `Timeout| `Closed| `Error of Unix.error * string * string
] Sourceval pp_error :
Format.formatter ->
[< `Error of Unix.error * string * string | `Refused | `Timeout ] ->
unit Sourceval pp_write_error :
Format.formatter ->
[< `Closed | `Error of Unix.error * string * string | `Refused | `Timeout ] ->
unit Sourceval read :
Lwt_unix.file_descr ->
([> `Data of Cstruct.t | `Eof ], [> `Error of Unix.error * string * string ])
result
Lwt.t Sourceval write :
Lwt_unix.file_descr ->
Cstruct.t ->
(unit, [> `Error of Unix.error * string * string ]) result Lwt.t Sourceval writev :
Lwt_unix.file_descr ->
Cstruct.t list ->
(unit, [> `Error of Unix.error * string * string ]) Lwt_result.t Sourceval close : Lwt_unix.file_descr -> unit Lwt.t Sourceval shutdown :
Lwt_unix.file_descr ->
[< `read | `read_write | `write ] ->
unit Lwt.t Sourcetype endpoint = Lwt_unix.sockaddr Sourceval connect :
Lwt_unix.sockaddr ->
(Lwt_unix.file_descr, [> `Error of Unix.error * string * string ]) result
Lwt.t Sourcetype listener = {process : flow -> unit Lwt.t;keepalive : Tcpip.Tcp.Keepalive.t option;
} Sourceval disconnect : 'a -> 'b Sourceval write_nodelay : 'a -> 'b -> 'c Sourceval writev_nodelay : 'a -> 'b -> 'c Sourceval create_connection : ?keepalive:'a -> 'b -> 'c -> 'd