Queue from source, emitting when thresholds are reached. The resulting Reactive produces arrays.
source
Can use a combination of elapsed time or number of data items.
By default options are OR'ed together.
// Emit data in chunks of 5 itemschunk(source, { quantity: 5 });// Emit a chunk of data every secondchunk(source, { elapsed: 1000 }); Copy
// Emit data in chunks of 5 itemschunk(source, { quantity: 5 });// Emit a chunk of data every secondchunk(source, { elapsed: 1000 });
Queue from
source, emitting when thresholds are reached. The resulting Reactive produces arrays.Can use a combination of elapsed time or number of data items.
By default options are OR'ed together.