New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Readable.flatMap
concurrency isn't working as expected
#52796
Labels
stream
Issues and PRs related to the stream subsystem.
Comments
I think the issue is this implementation: node/lib/internal/streams/operators.js Lines 345 to 352 in 743aa42
it relays on |
CC @nodejs/streams |
very odd one indeed! |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Version
v22.0.0
Platform
Darwin Moshes-MBP.localdomain 23.3.0 Darwin Kernel Version 23.3.0: Wed Dec 20 21:30:44 PST 2023; root:xnu-10002.81.5~7/RELEASE_ARM64_T6000 arm64
Subsystem
stream
What steps will reproduce the bug?
Run this code:
How often does it reproduce? Is there a required condition?
allways
What is the expected behavior? Why is that the expected behavior?
since
concurrency
is set to 200 - I expect all the chunks to be emitted together, however there is a second between each chuck:What do you see instead?
Additional information
when running similar code using
Readable.map
the concurrency works as expected:results in
The text was updated successfully, but these errors were encountered: