Skip to content

Commit 6e5f6fc

Browse files
committed
fixup! stream: add stream.compose
1 parent bb6bedf commit 6e5f6fc

2 files changed

Lines changed: 1 addition & 15 deletions

File tree

lib/internal/streams/compose.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ const {
99
isIterable,
1010
isReadableNodeStream,
1111
isWritableNodeStream,
12+
isNodeStream,
1213
isDestroyed,
1314
isReadableFinished,
1415
isWritableEnded,

lib/internal/streams/utils.js

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,6 @@ function isWritableEnded(stream) {
8888
return wState.ended;
8989
}
9090

91-
<<<<<<< HEAD
9291
// Have emitted 'finish'.
9392
function isWritableFinished(stream, strict) {
9493
if (!isWritableNodeStream(stream)) return null;
@@ -112,8 +111,6 @@ function isReadableEnded(stream) {
112111
return rState.ended;
113112
}
114113

115-
=======
116-
>>>>>>> 3980333d56... stream: add stream.compose
117114
// Have emitted 'end'.
118115
function isReadableFinished(stream, strict) {
119116
if (!isReadableNodeStream(stream)) return null;
@@ -126,7 +123,6 @@ function isReadableFinished(stream, strict) {
126123
);
127124
}
128125

129-
<<<<<<< HEAD
130126
function isDisturbed(stream) {
131127
return !!(stream && (
132128
stream.readableDidRead ||
@@ -145,21 +141,10 @@ module.exports = {
145141
isReadable,
146142
isReadableNodeStream,
147143
isReadableEnded,
148-
=======
149-
module.exports = {
150-
isReadable,
151-
isStream,
152-
isDestroyed,
153-
isIterable,
154-
isReadableNodeStream,
155-
>>>>>>> 3980333d56... stream: add stream.compose
156144
isReadableFinished,
157145
isNodeStream,
158146
isWritable,
159147
isWritableNodeStream,
160148
isWritableEnded,
161-
<<<<<<< HEAD
162149
isWritableFinished,
163-
=======
164-
>>>>>>> 3980333d56... stream: add stream.compose
165150
};

0 commit comments

Comments
 (0)