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
Release files for aiosubpub 2.0.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| aiosubpub-2.0.0.tar.gz | 5.3 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| aiosubpub-2.0.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 9.5 kB
Release files / aiosubpub-2.0.0.tar.gz
| Download URL | aiosubpub-2.0.0.tar.gz |
|---|---|
| Size | 5.3 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
077da952d4f242c605336915c24977b391b7fc66fcf6ec14804a40d61d4eb444
|
|
BLAKE2b-256 checksum How to use checksums |
0c397042159d2d2033ae92bd42a3f9c10140af8ad8ae5856e8664a802223643a
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
python-requests/2.27.1
|
Release files / aiosubpub-2.0.0-py3-none-any.whl
| Download URL | aiosubpub-2.0.0-py3-none-any.whl |
|---|---|
| Size | 4.1 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
a29b2a2ac34d5907505bddd1418c9aa76d9878779373f36d212aafa71c367ecc
|
|
BLAKE2b-256 checksum How to use checksums |
31d88b1b20422085b1c86b7dba1870c243c7445c1ede5a13a02accb28b34af04
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
python-requests/2.27.1
|
