Debounce#

class ultimo.pipelines.Debounce(delay=0.01, source=None)#

Pipeline that stabilizes polled values emitted for a short time.

Methods

create_task()

Create a task that consumes the source.

process(value)

run()

Consume the source if available.

Attributes

source

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.

source: ASource | None#

The input source for the pipeline.