diff --git a/src/Node.Stream.Object.js b/src/Node.Stream.Object.js index f3af9fc..db8ee5e 100644 --- a/src/Node.Stream.Object.js +++ b/src/Node.Stream.Object.js @@ -30,7 +30,7 @@ export const writeImpl = (s) => (a) => () => { - if (s.closed || s.writableEnded) { + if (s.writableEnded) { return closed; } @@ -46,7 +46,7 @@ export const readImpl = ({ just, closed, wouldBlock }) => (s) => () => { - if (s.closed || s.readableEnded) { + if (s.readableEnded) { return closed; }