ultimo.pipelines

Core pipeline classes for common operations

Functions

afilter(afn)	Decorator that produces a filter from an async function.
apipe(afn)	Decorator that produces a pipeline from an async function.
filter(fn)	Decorator that produces a filter from a function.
pipe(fn)	Decorator that produces a pipeline from a function.

Classes

Apply(coroutine[, args, kwargs, source])	Pipeline that applies a callable to each value.
Debounce([delay, source])	Pipeline that stabilizes polled values emitted for a short time.
Dedup([source])	Pipeline that ignores repeated values.
DedupFlow(source)
EWMA([weight, source])	Pipeline that smoothes values with an exponentially weighted moving average.
Filter(filter[, args, kwargs, source])	Pipeline that filters values.

Functions

ultimo.pipelines.afilter(afn)

Decorator that produces a filter from an async function.

ultimo.pipelines.apipe(afn)

Decorator that produces a pipeline from an async function.

ultimo.pipelines.filter(fn)

Decorator that produces a filter from a function.

ultimo.pipelines.pipe(fn)

Decorator that produces a pipeline from a function.