We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
concat(...streams) to add each next stream to the end of previous one
concat(...streams)
concat([1,2,3], [4,5,6]) => [1,2,3,4,5,6]
merge(...steams) to take items one by one from each stream to build new stream
merge(...steams)
merge([1,2,3], [4,5,6]) => [1,4,2,5,3,6]
combine(combineFn, ...streams) to create new stream where each item is calculated using according items from source streams
combine(combineFn, ...streams)
const add = (a,b) => a + b; combine(add, [1,2,3], [4,5,6]) => [5,7,9]
zip(...streams) creates an array of arrays using combine() under the hood
zip(...streams)
combine()
zip([1,2,3], [4,5,6]) => [[1,4], [2,5], [3,6]]; // equivalent to combine((...args) => args, [1,2,3], [4,5,6]);
The text was updated successfully, but these errors were encountered:
No branches or pull requests
concat(...streams)
to add each next stream to the end of previous onemerge(...steams)
to take items one by one from each stream to build new streamcombine(combineFn, ...streams)
to create new stream where each item is calculated using according items from source streamszip(...streams)
creates an array of arrays usingcombine()
under the hoodThe text was updated successfully, but these errors were encountered: