sig
type ('a, 'b) t
val return : 'a -> ('a, 'b) Duppy.Monad.t
val raise : 'b -> ('a, 'b) Duppy.Monad.t
val bind :
('a, 'b) Duppy.Monad.t ->
('a -> ('c, 'b) Duppy.Monad.t) -> ('c, 'b) Duppy.Monad.t
val ( >>= ) :
('a, 'b) Duppy.Monad.t ->
('a -> ('c, 'b) Duppy.Monad.t) -> ('c, 'b) Duppy.Monad.t
val run :
return:('a -> unit) ->
raise:('b -> unit) -> ('a, 'b) Duppy.Monad.t -> unit
val catch :
('a, 'b) Duppy.Monad.t ->
('b -> ('a, 'c) Duppy.Monad.t) -> ('a, 'c) Duppy.Monad.t
val ( =<< ) :
('b -> ('a, 'c) Duppy.Monad.t) ->
('a, 'b) Duppy.Monad.t -> ('a, 'c) Duppy.Monad.t
val fold_left :
('a -> 'b -> ('a, 'c) Duppy.Monad.t) ->
'a -> 'b list -> ('a, 'c) Duppy.Monad.t
val iter :
('a -> (unit, 'b) Duppy.Monad.t) -> 'a list -> (unit, 'b) Duppy.Monad.t
module Mutex :
sig
module type Mutex_control =
sig
type priority
val scheduler :
Duppy.Monad.Mutex.Mutex_control.priority Duppy.scheduler
val priority : Duppy.Monad.Mutex.Mutex_control.priority
end
module type Mutex_t =
sig
type mutex
module Control : Mutex_control
val create : unit -> Duppy.Monad.Mutex.Mutex_t.mutex
val lock :
Duppy.Monad.Mutex.Mutex_t.mutex -> (unit, 'a) Duppy.Monad.t
val try_lock :
Duppy.Monad.Mutex.Mutex_t.mutex -> (bool, 'a) Duppy.Monad.t
val unlock :
Duppy.Monad.Mutex.Mutex_t.mutex -> (unit, 'a) Duppy.Monad.t
end
module Factory : functor (Control : Mutex_control) -> Mutex_t
end
module Condition :
sig
module Factory :
functor (Mutex : Mutex.Mutex_t) ->
sig
type condition
val create : unit -> Duppy.Monad.Condition.Factory.condition
val wait :
Duppy.Monad.Condition.Factory.condition ->
Mutex.mutex -> (unit, 'a) Duppy.Monad.t
val broadcast :
Duppy.Monad.Condition.Factory.condition ->
(unit, 'a) Duppy.Monad.t
val signal :
Duppy.Monad.Condition.Factory.condition ->
(unit, 'a) Duppy.Monad.t
end
end
module Io :
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
end