AWrite

class ultimo.stream.AWrite(stream=<_io.TextIOWrapper name='<stdout>' mode='w' encoding='utf-8'>, source=None)

Write to a stream asynchronously.

Methods

close()	Close the output stream.
create_task()	Create a task that consumes the source.
process(source_value)	Write data to the stream and drain.
run()	Consume the source if available.

Attributes

source

The input source for the pipeline.

async close()

Close the output stream.

create_task() → uasyncio.Task

Create a task that consumes the source.

async process(source_value)

Write data to the stream and drain.

async run()

Consume the source if available.

source: ASource | None

The input source for the pipeline.