ASink#
- class ultimo.core.ASink(source=None)#
Base class for consumers of sources.
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.
- async run()#
Consume the source if available.