package duppy

  1. Overview
  2. Docs
type socket = Io.socket
type marker = Io.marker =
  1. | Length of int
  2. | Split of string
type failure = Io.failure =
  1. | Io_error
  2. | Unix of Unix.error * string * string
  3. | Unknown of exn
  4. | Timeout
val read : ?recursive:bool -> ?init:string -> ?on_error:((string * failure) -> unit) -> ?timeout:float -> priority:'a -> 'a scheduler -> socket -> marker -> ((string * string option) -> unit) -> unit
val write : ?exec:(unit -> unit) -> ?on_error:(failure -> unit) -> ?bigarray:bigarray -> ?string:string -> ?timeout:float -> priority:'a -> 'a scheduler -> socket -> unit