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 details)
Built Distribution
File details
Details for the file aiosubpub-2.0.0.tar.gz
.
File metadata
- Download URL: aiosubpub-2.0.0.tar.gz
- Upload date:
- Size: 5.3 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: python-requests/2.27.1
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 077da952d4f242c605336915c24977b391b7fc66fcf6ec14804a40d61d4eb444 |
|
MD5 | 2ab20e51efb9f8e8add0a8070a505494 |
|
BLAKE2b-256 | 0c397042159d2d2033ae92bd42a3f9c10140af8ad8ae5856e8664a802223643a |
File details
Details for the file aiosubpub-2.0.0-py3-none-any.whl
.
File metadata
- Download URL: aiosubpub-2.0.0-py3-none-any.whl
- Upload date:
- Size: 4.1 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: python-requests/2.27.1
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | a29b2a2ac34d5907505bddd1418c9aa76d9878779373f36d212aafa71c367ecc |
|
MD5 | 395d1d44aac79431b6bf23bc940fbf26 |
|
BLAKE2b-256 | 31d88b1b20422085b1c86b7dba1870c243c7445c1ede5a13a02accb28b34af04 |