Pubsub system for aio framework
Project description
aio.signals
===========
Pubsub system for the aio_ asyncio framework
.. _aio: https://github.com/phlax/aio
----
Build status
------------
.. image:: https://travis-ci.org/phlax/aio.signals.svg?branch=master
:target: https://travis-ci.org/phlax/aio.signals
----
Installation
------------
Install with:
.. code:: bash
pip install aio.signals
----
Code example
------------
.. code:: python
The callback listener takes 2 arguments, the name of the signal, and the argument that was emitted
The listen function is called synchronously, but the callback listener should be a coroutine or future
The emit function is a coroutine
.. code:: python
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!'))
===========
Pubsub system for the aio_ asyncio framework
.. _aio: https://github.com/phlax/aio
----
Build status
------------
.. image:: https://travis-ci.org/phlax/aio.signals.svg?branch=master
:target: https://travis-ci.org/phlax/aio.signals
----
Installation
------------
Install with:
.. code:: bash
pip install aio.signals
----
Code example
------------
.. code:: python
The callback listener takes 2 arguments, the name of the signal, and the argument that was emitted
The listen function is called synchronously, but the callback listener should be a coroutine or future
The emit function is a coroutine
.. code:: python
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!'))
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
aio.signals-0.0.1.tar.gz
(2.9 kB
view hashes)