Because everything is built with basic python building blocks, framework-like features can be crafted with ease. For instance, while timers aren’t included, you can whip one up effortlessly:

from asyncio import run, sleep

async def timer(interval=1.0):
    while True:
        await sleep(interval)
        yield

We’ll use print as our sink:

Let’s send our mascot 🐟 – blub downstream on a regular 1 second interval:

from slipstream import handle, stream

@handle(timer(), sink=[print])
def handler():
    yield '🐟 - blub'

run(stream())


# 🐟 - blub
# 🐟 - blub
# 🐟 - blub
# ...

Some things that stand out:

• We’ve created an Async Iterable source timer() (not generating data, just triggering the handler)

• We used slipstream.handle to bind the sources and sinks to the handler function

• We yielded 🐟 - blub, which is sent to all the Callable sinks (just print in this case)

• Running slipstream.stream starts the flow from sources via handlers into the sinks

The data-flow model that simplifies development of stateful streaming applications!

Contents¶

Proceed by interacting with Kafka and caching application state in: getting started.