On (p.sel.0.5.0.doc.sel.Sel.On)

type 'a res = ('a, exn) result

val line : 
  ?priority:int ->
  ?name:string ->
  Unix.file_descr ->
  (string res -> 'a) ->
  'a Event.t

a line, terminated by '\n'

val bytes : 
  ?priority:int ->
  ?name:string ->
  Unix.file_descr ->
  int ->
  (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

val ocaml_value : 
  ?priority:int ->
  ?name:string ->
  Unix.file_descr ->
  ('b res -> 'a) ->
  'a Event.t

any value (not type safe, uses Marshall)

val httpcle : 
  ?priority:int ->
  ?name:string ->
  Unix.file_descr ->
  (Bytes.t res -> 'a) ->
  'a Event.t

HTTP Content Length encoded data

val queues : 
  ?priority:int ->
  ?name:string ->
  'b Queue.t ->
  'c 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 Queue.t ->
  ('b -> 'a) ->
  'a Event.t

Synchronization events between a component and an event