NewYour coding agent can read the release notes before it upgrades.Set up the MCP server →
PyPI · #1973 most downloaded on PyPI
Generator-based operators for asynchronous iteration
Last release 18 days ago
16 Sep 2026
Ships fairly regularly
a new release about every 7 months
Most releases are documented
notes for 26 of 30 stable releases
Nothing withdrawn
no release was ever pulled
10 years old
31 releases · first in 2016
Fix repeated source consumption in sequential combine by @Kuang-xianxin in #146
Full Changelog: v0.8.0...v0.8.1
Fix zip cleanup of pending source pulls by @Kuang-xianxin in #144
Full Changelog: v0.7.2...v0.8.0
One column per quarter.
Change return type of return Callable annotation in async_ to Coroutine[Any, Any, T] , which is narrower than Awaitable[T] by @jonathandung in #139
Callable annotation in async_ to Coroutine[Any, Any, T], which is narrower than Awaitable[T] by @jonathandung in #139asyncio.iscoroutinefunction with inspect.iscoroutinefunction by @vxgmichel in #142Full Changelog: v0.7.1...v0.7.2
Fix typing for stream.create.just by @vxgmichel in #134
zip of items that fail on __eq__ by @vthemelis in #135is instead of isinstance by @vthemelis in #136Full Changelog: v0.7.0...v0.7.1
Improve performance for sequential combine operations ( task_limit=1 ) by @vxgmichel in #131
task_limit=1) by @vxgmichel in #131Full Changelog: v0.6.4...v0.7.0
Drop support for python 3.8, add support for python 3.13 by @fpgmaas in #123
Add MANIFEST.in to include tests/conftests.py in source dist by @vxgmichel (issue #121 , PR #122 )
MANIFEST.in to include tests/conftests.py in source dist by @vxgmichel (issue #121, PR #122)Full Changelog: v0.6.2...v0.6.3
Fixing the issue of the lack of installation sections by @thepapermen in #113
Full Changelog: v0.6.1...v0.6.2
Expose Stream and sources_operator in the aiostream package
Add sources operator to fix a breaking change in v0.5.x (PR #108 , issue #95 )
setup.* to pyproject.toml (PR #101, #102, #103, #110)aiostream.test_utils (PR #104)Thanks to @hf-kklein for the valuable contributions :)
Nothing published for this version
Warning The 0.5.x releases are affected by an unintentional breaking change, see the v0.5.0 release for more information.
Warning The 0.5.x releases are affected by an unintentional breaking change, see the v0.5.0 release for more information.
> A breaking change has slipped into this release: The merge, chain and ziplatest operators used to work with no sources provided:
[!WARNING] A breaking change has slipped into this release: The
merge,chainandziplatestoperators used to work with no sources provided:assert await (stream.merge() | pipe.list()) == [] assert await (stream.chain() | pipe.list()) == [] assert await (stream.ziplatest() | pipe.list()) == []This is no longer the case for releases
0.5.x, where at least one async iterable has to be provided for those operators. This can be a problem for code that passes an arbitrary list of arguments to the operator, as this list might be empty. A workaround exists for themergeoperator, which works by addingstream.empty()to the list of arguments:args = [] new_args = stream.empty(), *args assert await (stream.merge(*new_args) | pipe.list()) == []The
zipoperator should have also been affected, although the former version had a bug that caused an empty zip to block indefinitely.This change has been fixed in v0.6.0
Build and upload a wheel package to PyPI
Build and upload a wheel package to PyPI
Fix confusing traceback when calling wait_stream on a empty stream (issue #76, PR #77)
Fix several issues with the task group (issue #73, PR #75)
Add python 3.8 and 3.9 support (PR #63)
Better error handling in user code (PR #47)
Implement call operator (PR #43)
Set encoding to utf-8 in setup script (PR #42)
PR #27: Fixed deprecation warning for importing ABC's from collections
base_combine and the streamer managerAsyncIteratorContext now re-throws exceptions within the iteratorAsyncExitStack from contextlibIssue #20, PR #21: Add await_ and async_ helper functions
PR #10: add concurrency to map and starmap operators
map and starmap operators
ordered argument can be used to get the elements either in order or as soon as possible.task_limit can be used to limit the amount of mapping coroutines that can run concurrently.Issue #7, PR #8: add proper cleanup for merge operator
merge operatorconcat, flatten, switch and their corresponding *map operatorsAdd github context to the documentation
Fix typo in docs, readme and docstrings.
Fix typo in docs, readme and docstrings.
Nothing published for this version
Nothing published for this version
Nothing published for this version
Nothing published for this version
Your coding agent can read these notes before it upgrades. Set up the MCP server →