aio.signals 0.0.6

Pubsub system for aio framework

Pubsub system for the aio asyncio framework

Build status

Installation

Requires python >= 3.4 to work

Install with:

pip install aio.signals

Quickstart

The listen function is called synchronously, but the callback listener will be called as a coroutine if it isnt one

The callback listener takes 2 arguments, the name of the signal, and the argument that was emitted

The emit function is a coroutine

Add the following code to a file my_signals.py

import asyncio
from aio.signals import Signals

@asyncio.coroutine
def listener(signal, message):
    print(message)

signals = Signals()
signals.listen("my-signal", listener)

loop = asyncio.get_event_loop()
loop.run_until_complete(
    signals.emit("my-signal", 'BOOM!'))

Run with

python my_signals.py