sig
type ('a, 'b) handler = {
scheduler : 'a Duppy.scheduler;
socket : Unix.file_descr;
mutable data : string;
on_error : Duppy.Io.failure -> 'b;
}
val exec :
?delay:float ->
priority:'a ->
('a, 'b) Duppy.Monad.Io.handler ->
('c, 'b) Duppy.Monad.t -> ('c, 'b) Duppy.Monad.t
val delay :
priority:'a ->
('a, 'b) Duppy.Monad.Io.handler -> float -> (unit, 'b) Duppy.Monad.t
val read :
?timeout:float ->
priority:'a ->
marker:Duppy.Io.marker ->
('a, 'b) Duppy.Monad.Io.handler -> (string, 'b) Duppy.Monad.t
val read_all :
?timeout:float ->
priority:'a ->
'a Duppy.scheduler ->
Unix.file_descr -> (string, string * Duppy.Io.failure) Duppy.Monad.t
val write :
?timeout:float ->
priority:'a ->
('a, 'b) Duppy.Monad.Io.handler -> string -> (unit, 'b) Duppy.Monad.t
val write_bigarray :
?timeout:float ->
priority:'a ->
('a, 'b) Duppy.Monad.Io.handler ->
Duppy.Io.bigarray -> (unit, 'b) Duppy.Monad.t
end