diff --git a/src/functions/accumulator.ts b/src/functions/accumulator.ts index 82ca9ae..c4ac31a 100644 --- a/src/functions/accumulator.ts +++ b/src/functions/accumulator.ts @@ -59,7 +59,7 @@ function _sliding( buffer.shift(); } buffer.push(event); - stream.push(buffer); + stream.push([...buffer]); }; } @@ -73,7 +73,7 @@ function _slidingByFunction( } buffer.splice(0, index); buffer.push(event); - stream.push(buffer); + stream.push([...buffer]); }; }