package riot
Module Net.SocketSource
Source
val listen :
?opts:listen_opts ->
port:int ->
unit ->
(listen_socket, [> `System_limit ]) resultSource
val accept :
?timeout:timeout ->
listen_socket ->
(stream_socket * Addr.stream_addr, [> `Closed | `Timeout | `System_limit ])
resultSource
val receive :
?timeout:timeout ->
len:int ->
stream_socket ->
(Bigstringaf.t, [> `Closed | `Timeout ]) result