| Overview |  |
Behaviours: gen_flow.
| init/1 | Initialize state. |
| process/2 | Computation to execute when inputs change. |
| read/1 | Return list of read functions. |
| single_fire_function/4 | Track a function in the dag. |
| start_dag_link/1 | |
| start_link/1 | |
| start_manual_process/1 | A lasp process that shouldn't be automatically managed by the dag. |
| start_single_fire_process/1 | Starts a single-fire lasp process. |
init(X1) -> any()
Initialize state.
process(Args, State) -> any()
Computation to execute when inputs change.
read(State) -> any()
Return list of read functions.
single_fire_function(From, To, Fn, Args) -> any()
Track a function in the dag.
Given the input and output variables, and a function, create a single-fire lasp process representing the dataflow computation.
This function is synchronous, as it waits for a value to be returned.start_dag_link(Args) -> any()
start_link(X1) -> any()
start_manual_process(Args) -> any()
A lasp process that shouldn't be automatically managed by the dag
When using this function, the resulting process isn't tracked by the runtime. Only useful when we want to manually introduce the dependencies in the graph, or for functions that aren't currently supported (fold and stream).start_single_fire_process(Args) -> any()
Starts a single-fire lasp process.
These processes only run until their transform functions complete succesfully one time. Used to model reads and binds on values.Generated by EDoc