Aio sub pub package.
Project description
AioSubPub
Async pub sub implementation.
Inspired by someone else whose name I cannot find anymore. If you see your code (I did some improvements on it I think) please let me know and I am happy to give you credit.
Installation
pip install aiosubpub
Usage
import aiosubpub import asyncio loop=asyncio.get_event_loop() # create a channel a_channel = aiosubpub.Channel() # subscribe to the channel using a callback. def call_back(data): print(data) subscription = loop.create_task(a_channel.subscribe(call_back)) # Publish a message. a_channel.publish("a message") subscription.un_subscribe() # Without callback: subscription = a_channel.get_subscription() async def _custom_subscriber(): with subscription as sub: result = await sub.get() print(result) a_channel.publish("a message") result = await _custom_subscriber()
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.
Filename, size | File type | Python version | Upload date | Hashes |
---|---|---|---|---|
Filename, size aiosubpub-1.0.9-py3-none-any.whl (4.0 kB) | File type Wheel | Python version py3 | Upload date | Hashes View |
Filename, size aiosubpub-1.0.9.tar.gz (4.8 kB) | File type Source | Python version None | Upload date | Hashes View |
Close
Hashes for aiosubpub-1.0.9-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 58070279726f07de014e1677172477e7c373158cbab4180b8d97508f23fd9533 |
|
MD5 | 54279b7245cb67b383cb122e94b48d48 |
|
BLAKE2-256 | 1063e5591314ebbd296ac5e1167067eb002900b099241575e69b2f342143f3fb |