Apply#
- class ultimo.pipelines.Apply(coroutine, args=(), kwargs={}, source=None)#
Pipeline that applies a callable to each value.
Methods
Create a task that consumes the source.
process
(value)run
()Consume the source if available.
Attributes
The input source for the pipeline.
- create_task() uasyncio.Task #
Create a task that consumes the source.
- flow#
alias of
APipelineFlow
- async run()#
Consume the source if available.