Aio sub pub包。
项目描述
AioSubPub
异步发布订阅实现。
灵感来源于我已无法找到名字的人。如果您看到您的代码（我认为我在它上面做了一些改进），请告诉我，我很乐意给您致谢。
安装
pip install aiosubpub
用法
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()
变更日志
1.0.10
- 将
get_latest添加到频道。
下载文件
下载适用于您的平台的文件。如果您不确定选择哪个，请了解更多关于安装包的信息。
源分布
aiosubpub-2.0.0.tar.gz (5.3 kB 查看哈希值)
构建分布
aiosubpub-2.0.0-py3-none-any.whl (4.1 kB 查看哈希值)
关闭
aiosubpub-2.0.0.tar.gz的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 077da952d4f242c605336915c24977b391b7fc66fcf6ec14804a40d61d4eb444 |
|
| MD5 | 2ab20e51efb9f8e8add0a8070a505494 |
|
| BLAKE2b-256 | 0c397042159d2d2033ae92bd42a3f9c10140af8ad8ae5856e8664a802223643a |