Aio Sub-pub套餐。
aiosubpub的Python项目详细描述
AioSubPub公司
异步发布订阅实现。在
灵感来自另一个我再也找不到名字的人。如果你看到你的代码（我想我做了一些改进），请让我知道，我很高兴给你学分。在
安装
pip install aiosubpub
使用
importaiosubpubimportasyncioloop=asyncio.get_event_loop()# create a channela_channel=aiosubpub.Channel()# subscribe to the channel using a callback.defcall_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()asyncdef_custom_subscriber():withsubscriptionassub:result=awaitsub.get()print(result)a_channel.publish("a message")result=await_custom_subscriber()
- 项目
标签：
欢迎加入QQ群-->： 979659372
