yumoqing
cb7766defa
宿主未调 set_use_socks5() 时（如 pipeline_app），请求异常分支引用 use_socks5_proxy 直接 NameError，把真实网络错误掩盖成 'ingest 异常: NameError'。拼写修正恢复默认 True 语义。
appPublic
a set of icommon modules for python development
EventDispatcher
生产级异步事件调度器。
特性
- 支持普通函数
- 支持 async 协程
- 支持实例方法
- 弱引用自动GC
- 异常隔离
- 超时控制
- 自定义错误处理
使用示例
import asyncio
from event_dispatcher import EventDispatcher
def on_login(data):
print(data)
async def main():
dispatcher = EventDispatcher()
dispatcher.bind(
"login",
on_login
)
await dispatcher.dispatch(
"login",
{
"user": "张三"
}
)
asyncio.run(main())