new_wukong/plugins/example.py
ZZY 6120e7ba57 refactor(main): 使用异步流处理替换原有的顺序执行
重构`main`函数,将原先的顺序执行模型改为基于异步流的处理方式,利用`aiostream`库实现更高效的并发数据处理。
2024-08-31 14:36:44 +08:00

8 lines
142 B
Python

from aiostream import stream, pipe, Stream
class MyExecute():
def __init__(self):
pass
def execute(self, data):
pass