ultimo.core

Core classes and helper functions for the Ultimo framework

Functions

aconnect(source, sink)	Connect a sink to consume a source.
aiter(iterable)	Return an asynchronous iterator for an object.
anext(iterator)	Return the next item from an asynchronous iterator.
asink(afn)	Turn an asynchronous function into a sink.
asynchronize(f)	Make a synchronous callback synchronouse.
connect(source, sink)	Connect a sink to consume a source.
sink(fn)	Turn a synchronous function into a sink.

Classes

AFlow(source)	Base class for iterators over sources.
APipeline([source])	Base class for combined source/sink objects.
APipelineFlow(source)	Base class for iterators over pipeline sources.
ASink([source])	Base class for consumers of sources.
ASource()	Base class for asynchronous sources.
Consumer(consumer[, args, kwargs, source])	A sink that wraps an asynchronous coroutine.
EventFlow(source)	Flow which awaits an Event and then gets the source value.
EventSource()	Base class for event-driven sources.
ThreadSafeSource()	Base class for interrupt-driven sources.

Functions

async ultimo.core.aconnect(source, sink)

Connect a sink to consume a source.

ultimo.core.aiter(iterable)

Return an asynchronous iterator for an object.

async ultimo.core.anext(iterator)

Return the next item from an asynchronous iterator.

ultimo.core.asink(afn)

Turn an asynchronous function into a sink.

ultimo.core.asynchronize(f)

Make a synchronous callback synchronouse.

async ultimo.core.connect(source, sink)

Connect a sink to consume a source.

ultimo.core.sink(fn)

Turn a synchronous function into a sink.