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_latestto the channel.
1 maintainer
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
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
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
|
