toArray

Collects all source emissions and emits them as an array when the source completes.

Get all values inside an array when the source completes

toArray will wait until the source Observable completes before emitting the array containing all emissions. When the source Observable errors no array will be emitted.

Example

import { interval, take, toArray } from 'rxjs';

const source = interval(1000);
const example = source.pipe(
  take(10),
  toArray()
);

example.subscribe(value => console.log(value));

// output: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]