package current-web-pipelines

  1. Overview
  2. Docs

Module Current_web_pipelines.TaskSource

Sourcetype ('current, 'state) t

A pipeline with current 'current and metadata 'state. the current can be blocking, but the state shouldn't.

Sourcetype 'state simple = (unit, 'state) t
Sourceval current : ('current, _) t -> 'current Current.t

Extractors

Sourceval state : (_, 'state) t -> 'state Current.t

Constructors

Sourceval v : current:'current Current.t -> state:'state Current.t -> ('current, 'state) t

Operations

Sourceval list_iter : collapse_key:string -> (module Current_term.S.ORDERED with type t = 'a) -> ('a Current.t -> (unit, 'state) t) -> 'a list Current.t -> (unit, 'state list) t
Sourceval all : (unit, 'state) t list -> (unit, 'state list) t
Sourceval list_seq : ('current, 'state) t list -> ('current list, 'state list) t
Sourceval map_state : ('state -> 'next_state) -> ('current, 'state) t -> ('current, 'next_state) t
Sourceval map_current : ('current -> 'next_current) -> ('current, 'state) t -> ('next_current, 'state) t
Sourceval apply_current : ('current Current.t -> 'next_current Current.t) -> ('current, 'state) t -> ('next_current, 'state) t

Specialized constructors

Sourceval single : 'metadata -> 'output Current.t -> ('output, ('output, 'metadata) State.job_tree) t
Sourceval single_c : 'metadata Current.t -> 'output Current.t -> ('output, ('output, 'metadata) State.job_tree) t
OCaml

Innovation. Community. Security.