sig
  type socket = Unix.file_descr
  module Io :
    sig
      type socket = Unix.file_descr
      type marker = Io.marker = Length of int | Split of string
      type bigarray =
          (char, Bigarray.int8_unsigned_elt, Bigarray.c_layout)
          Bigarray.Array1.t
      type failure =
        Io.failure =
          Io_error
        | Unix of Unix.error * string * string
        | Unknown of exn
        | 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:Bytes.t ->
        ?timeout:float -> priority:'a -> 'a scheduler -> socket -> unit
    end
  type ('a, 'b) handler = {
    scheduler : 'a scheduler;
    socket : Io.socket;
    mutable data : string;
    on_error : Io.failure -> 'b;
  }
  val exec :
    ?delay:float ->
    priority:'a -> ('a, 'b) handler -> ('c, 'b) t -> ('c, 'b) t
  val delay : priority:'a -> ('a, 'b) handler -> float -> (unit, 'b) t
  val read :
    ?timeout:float ->
    priority:'a -> marker:Io.marker -> ('a, 'b) handler -> (string, 'b) t
  val read_all :
    ?timeout:float ->
    priority:'a ->
    'a scheduler -> Io.socket -> (string, string * Io.failure) t
  val write :
    ?timeout:float ->
    priority:'a -> ('a, 'b) handler -> Bytes.t -> (unit, 'b) t
  val write_bigarray :
    ?timeout:float ->
    priority:'a -> ('a, 'b) handler -> Io.bigarray -> (unit, 'b) t
end