Skip to content

Commit ba3301f

Browse files
author
Tim Smart
committed
fix: emit initial readable
1 parent 0a7a4c2 commit ba3301f

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/internal/stream.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,10 @@ export const stream = <A>(
5050
stream.on("readable", () => {
5151
emit.single(stream)
5252
})
53+
54+
if (stream.readable) {
55+
emit.single(stream)
56+
}
5357
}, 0)
5458
),
5559
Stream.unwrapScoped,

0 commit comments

Comments
 (0)