From 1b10c610841dbc6b5db2d3a3ff316ee735901268 Mon Sep 17 00:00:00 2001 From: Leo Conforti Date: Tue, 22 Oct 2024 20:05:17 +0000 Subject: [PATCH] update multiplexed demux --- src/demux/Multiplexed.ts | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/src/demux/Multiplexed.ts b/src/demux/Multiplexed.ts index 5900cdf0..fe3ef917 100644 --- a/src/demux/Multiplexed.ts +++ b/src/demux/Multiplexed.ts @@ -271,12 +271,7 @@ export const demuxMultiplexedSocket: { Stream.map(({ messageBuffer, messageType }) => Tuple.make(messageType, Chunk.toReadonlyArray(messageBuffer)) ), - Stream.flatMap(Schema.decodeUnknown(MultiplexedStreamSocketSchema)), - Stream.filter( - ([messageType]) => - messageType === MultiplexedStreamSocketHeaderType.Stdout || - messageType === MultiplexedStreamSocketHeaderType.Stderr - ) + Stream.flatMap(Schema.decodeUnknown(MultiplexedStreamSocketSchema)) ); if (!willPartition) { @@ -290,7 +285,9 @@ export const demuxMultiplexedSocket: { return Function.pipe( untilPartition, - Stream.partition(([messageType]) => messageType === MultiplexedStreamSocketHeaderType.Stdout, options), + Stream.partition(([messageType]) => messageType !== MultiplexedStreamSocketHeaderType.Stderr, { + bufferSize: options?.bufferSize, + }), Effect.map( Tuple.mapBoth({ onFirst: Function.flow(