diff --git a/packages/it-length-prefixed-stream/src/index.ts b/packages/it-length-prefixed-stream/src/index.ts index 33e2d9f4..f8427e40 100644 --- a/packages/it-length-prefixed-stream/src/index.ts +++ b/packages/it-length-prefixed-stream/src/index.ts @@ -80,7 +80,7 @@ const defaultLengthDecoder: lp.LengthDecoderFunction = (buf) => { defaultLengthDecoder.bytes = 0 export function lpStream > (duplex: Stream, opts: Partial = {}): LengthPrefixedStream { - const bytes = byteStream(duplex) + const bytes = byteStream(duplex, opts) if (opts.maxDataLength != null && opts.maxLengthLength == null) { // if max data length is set but max length length is not, calculate the