Skip to main content
The Deno 2 Release Candidate is here
Learn more
Module

x/stream_observables/mod.ts>bufferWithCount

A collection of observables built with ReadableStreams & friends.
cloudydeno/deno-stream_observables
Latest
function bufferWithCount
import { bufferWithCount } from "https://deno.land/x/stream_observables@v1.3/mod.ts";

Collects items from the original observable into buffers of size count.

Parameters

count: number

Max size for the buffers.

Returns

Transform<T, T[]>

Transform that emits arrays of items from the original observable.