functor (Io : Io_t) ->
  sig
    type socket = Io.socket
    module Io :
      sig
        type socket = Io.socket
        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