data() = any()
operation() = term()
pipe() = atom()
flow/2 | Equivalent to run(Pipe, Data). |
new/2 | Create a new pipe. |
run/2 | Execute a pipe treatment. |
stop/1 | Destroy the given pipe. |
flow(Pipe, Data) -> any()
Equivalent to run(Pipe, Data)
.
new(Name::atom(), Operations::[operation()]) -> pipe()
Create a new pipe.
Execute a pipe treatment.
stop(Pipe::pipe()) -> ok | {error, term()}
Destroy the given pipe.