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

toArray<T>(): OperatorFunction<T, T[]>

Parameters

There are no parameters.

Returns

OperatorFunction<T, T[]>: A function that returns an Observable that emits an array of items emitted by the source Observable when source completes.

Description

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]