Skip to content

stream: add compose operator #44937

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.

Sign up for GitHub

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

Merged
nodejs-github-bot merged 7 commits into from
Oct 31, 2022
Merged

stream: add compose operator #44937

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
076bbe5
stream: add compose operator
rluvaton Oct 9, 2022
da9255f
stream: rename import
rluvaton Oct 9, 2022
273b0b6
stream: add abort signal support
rluvaton Oct 9, 2022
2e4898e
stream: add validation and refactor tests
rluvaton Oct 26, 2022
fed2ac3
stream: fix lint and add started adding docs
rluvaton Oct 26, 2022
da244b9
stream: added an example in the streams docs
rluvaton Oct 27, 2022
7e55077
stream: fix lint error
rluvaton Oct 29, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
stream: fix lint error
  • Loading branch information
@rluvaton
rluvaton committed Oct 29, 2022
commit 7e55077b63a6645c4ee302a5d54a197b6b2aa3da
6 changes: 4 additions & 2 deletions doc/api/stream.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1714,7 +1714,7 @@ const words = await wordsStream.toArray();
console.log(words); // prints ['this', 'is', 'compose', 'as', 'operator']
```

See [`stream.compose`](#streamcomposestreams) for more information.
See [`stream.compose`][] for more information.

##### `readable.iterator([options])`

Expand Down Expand Up @@ -2750,7 +2750,7 @@ await finished(compose(s1, s2, s3));
console.log(res); // prints 'HELLOWORLD'
```

See [`readable.compose`](#readablecomposestream-options) for `stream.compose` as operator.
See [`readable.compose(stream)`][] for `stream.compose` as operator.

### `stream.Readable.from(iterable[, options])`

Expand Down Expand Up @@ -4519,11 +4519,13 @@ contain multi-byte characters.
[`process.stdin`]: process.md#processstdin
[`process.stdout`]: process.md#processstdout
[`readable._read()`]: #readable_readsize
[`readable.compose(stream)`]: #readablecomposestream-options
[`readable.map`]: #readablemapfn-options
[`readable.push('')`]: #readablepush
[`readable.setEncoding()`]: #readablesetencodingencoding
[`stream.Readable.from()`]: #streamreadablefromiterable-options
[`stream.addAbortSignal()`]: #streamaddabortsignalsignal-stream
[`stream.compose`]: #streamcomposestreams
[`stream.cork()`]: #writablecork
[`stream.finished()`]: #streamfinishedstream-options-callback
[`stream.pipe()`]: #readablepipedestination-options
Expand Down