diff --git a/packages/it-byte-stream/src/index.ts b/packages/it-byte-stream/src/index.ts index eddcfb8c..ee372234 100644 --- a/packages/it-byte-stream/src/index.ts +++ b/packages/it-byte-stream/src/index.ts @@ -152,11 +152,13 @@ export function byteStream > (duplex: Strea } }, unwrap: () => { - const originalStream = duplex.source - duplex.source = (async function * () { - yield * readBuffer - yield * originalStream - }()) + if (readBuffer.byteLength > 0) { + const originalStream = duplex.source + duplex.source = (async function * () { + yield * readBuffer + yield * originalStream + }()) + } return duplex }