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()
changelog
1.0.10
- Add
get_latest
to the channel.
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
aiosubpub-2.0.0.tar.gz
(5.3 kB
view hashes)
Built Distribution
Close
Hashes for aiosubpub-2.0.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | a29b2a2ac34d5907505bddd1418c9aa76d9878779373f36d212aafa71c367ecc |
|
MD5 | 395d1d44aac79431b6bf23bc940fbf26 |
|
BLAKE2b-256 | 31d88b1b20422085b1c86b7dba1870c243c7445c1ede5a13a02accb28b34af04 |