Skip to content

Commit

Permalink
fixup! stream: add stream.compose
Browse files Browse the repository at this point in the history
  • Loading branch information
ronag committed Aug 23, 2021
1 parent bb6bedf commit 6e5f6fc
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 15 deletions.
1 change: 1 addition & 0 deletions lib/internal/streams/compose.js
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ const {
isIterable,
isReadableNodeStream,
isWritableNodeStream,
isNodeStream,
isDestroyed,
isReadableFinished,
isWritableEnded,
Expand Down
15 changes: 0 additions & 15 deletions lib/internal/streams/utils.js
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,6 @@ function isWritableEnded(stream) {
return wState.ended;
}

<<<<<<< HEAD
// Have emitted 'finish'.
function isWritableFinished(stream, strict) {
if (!isWritableNodeStream(stream)) return null;
Expand All @@ -112,8 +111,6 @@ function isReadableEnded(stream) {
return rState.ended;
}

=======
>>>>>>> 3980333d56... stream: add stream.compose
// Have emitted 'end'.
function isReadableFinished(stream, strict) {
if (!isReadableNodeStream(stream)) return null;
Expand All @@ -126,7 +123,6 @@ function isReadableFinished(stream, strict) {
);
}

<<<<<<< HEAD
function isDisturbed(stream) {
return !!(stream && (
stream.readableDidRead ||
Expand All @@ -145,21 +141,10 @@ module.exports = {
isReadable,
isReadableNodeStream,
isReadableEnded,
=======
module.exports = {
isReadable,
isStream,
isDestroyed,
isIterable,
isReadableNodeStream,
>>>>>>> 3980333d56... stream: add stream.compose
isReadableFinished,
isNodeStream,
isWritable,
isWritableNodeStream,
isWritableEnded,
<<<<<<< HEAD
isWritableFinished,
=======
>>>>>>> 3980333d56... stream: add stream.compose
};

0 comments on commit 6e5f6fc

Please sign in to comment.