package duppy

  1. Overview
  2. Docs
type socket = Unix.file_descr
module Io : sig ... end
type (!'a, !'b) handler = {
  1. scheduler : 'a scheduler;
  2. socket : Io.socket;
  3. mutable data : string;
  4. 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 -> string -> (unit, 'b) t
val write_bigarray : ?timeout:float -> priority:'a -> ('a, 'b) handler -> Io.bigarray -> (unit, 'b) t