AnyIO implementation of asynchronous streams

未关闭

#320 创建于 2020年3月30日 14 条评论 1 个 reaction 已指派 0 人在 GitHub 查看

还没有人认领这个 Issue。

评估

难度: 5/5
预计耗时: 一周以上
新手友好度: 25/100

Issue 类型: 功能
描述清晰度: 基本清楚
活跃度: 停滞
技术栈: python
领域: stream-processing

调研方向

Start by reviewing streamz's current Tornado and asyncio support, then compare the integration requirements of AnyIO and the event loops it should enable, including Trio. Done means streamz has a usable AnyIO-based asynchronous stream implementation that supports the event-loop flexibility described in the issue.

由索引模型根据 Issue 内容生成。

描述

Using streamz with an event loop such as trio is currently not possible since Tornado only supports AsyncIO if it is available.

If we had an implementation that uses AnyIO, we could use any event loop we'd desire including tornado.

主要语言: Python
星标: 1.3k
派生: 149
PR 合并指标: 30 天内没有已合并 PR

贡献指南

打开贡献指南

从这里开始

先读完整个 Issue，再读项目的贡献指南。
在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
Fork 仓库，在一个分支上完成修改。
提交 Pull Request，并在描述里引用这个 Issue 编号。

python-streamz/streamz 的其他 Issue

pkg_resources warning 未关闭

难度 3/5 1-2 天新手友好度 35/100

python-streamz/streamz#481 · 4 条评论 · 2025年6月23日创建
Combining the streamz.Stream.filenames() and streamz.Stream.from_textfile() using dask scatter? 未关闭

难度 5/5 一周以上新手友好度 25/100

python-streamz/streamz#480 · 2 条评论 · 2025年2月10日创建
Compile the code into c++ 未关闭

难度 5/5 一周以上新手友好度 20/100

python-streamz/streamz#479 · 1 条评论 · 2024年10月28日创建
Suggestions for improving code performance 未关闭

难度 5/5 一周以上新手友好度 20/100

python-streamz/streamz#478 · 6 条评论 · 2024年9月17日创建
Is streamz not maintained anymore? What happened to cuStreamz? 未关闭

难度 4/5 3-5 天新手友好度 10/100

python-streamz/streamz#476 · 17 条评论 · 2 个 reaction · 2024年4月28日创建

查看 python-streamz/streamz 的全部 Issue

相似的 Issue

[BUG] GkeTpuCluster queries metadata.google.internal for MEGASCALE_SLICE_ID even when TPU_SKIP_MDS_QUERY is set 未关闭

难度 2/5 1-3 小时新手友好度 88/100

jax-ml/jax#40854 · 2026年9月22日创建
[pcied] Honour PCIE_DETACH_INFO on platforms that are not smartswitches 未关闭

难度 2/5 1-3 小时新手友好度 82/100

sonic-net/sonic-platform-daemons#900 · 2026年9月21日创建
MCP client has no httpx timeout, so the event stream fails after 5 seconds 未关闭

难度 2/5 1-3 小时新手友好度 78/100

Azure/azure-functions-agents-runtime#228 · 2026年9月21日创建
feat(mcp): friendlier error when `run_cloud_sync` is called on a disabled connection 未关闭

enhancement

难度 2/5 1-3 小时新手友好度 72/100

airbytehq/PyAirbyte#1205 · 2026年9月21日创建
pn7160: reader goes permanently deaf — post-read IRQ-low check fails reads that succeeded 未关闭

难度 2/5 1-3 小时新手友好度 74/100

esphome/esphome#19452 · 2026年9月21日创建

更多 Python Issue