Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
Events one can wait for (read data, pull from queues, ...)
name
for debug printingpriority
lower integers correspond to high priorities (as in Unix nice), default is 0a line, terminated by '\n'
val bytes :
?priority:int ->
?name:string ->
Unix.file_descr ->
int ->
(Stdlib.Bytes.t res -> 'a) ->
'a Event.t
bytes
val death_of :
?priority:int ->
?name:string ->
pid:int ->
(Unix.process_status -> 'a) ->
'a Event.t
termination of a process
any value (not type safe, uses Marshall
)
val httpcle :
?priority:int ->
?name:string ->
Unix.file_descr ->
(Stdlib.Bytes.t res -> 'a) ->
'a Event.t
HTTP Content Length encoded data
val queues :
?priority:int ->
?name:string ->
'b Stdlib.Queue.t ->
'c Stdlib.Queue.t ->
('b -> 'c -> 'a) ->
'a Event.t
Synchronization events between two components (e.g. a worker pool and a task queue) and an event (e.g. starting a worker)
val queue :
?priority:int ->
?name:string ->
'b Stdlib.Queue.t ->
('b -> 'a) ->
'a Event.t
Synchronization events between a component and an event