Consumer#
- class ultimo.core.Consumer(consumer, args=(), kwargs={}, source=None)#
A sink that wraps an asynchronous coroutine.
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.