Async pubsub implementation.
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.
Source Distribution
aiosubpub-1.0.2.tar.gz
(4.5 kB
view hashes)
Built Distribution
Close
Hashes for aiosubpub-1.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 9765618e612f8403bcab8f4aade570fcf91804dd2e7c27a1b28a8e5d6137b6ac |
|
MD5 | 3d28ba7b18fab645fd9ea801a7924507 |
|
BLAKE2b-256 | c036ef503a22f83a17cd30700b45c03feba36e01bd8d1fe30c09b2fc9abe1f54 |