Skip to main content

notificationsToValuesObservablePipe

Alternative: notificationsToValues$$$

Inlined: notificationsToValuesObservable, notificationsToValues$$

Types​

function notificationsToValuesObservablePipe<GValue>(
  onError?: INotificationsToValuesObservableOnErrorFunction,
  maxNumberOfValues?: number,
): IObservablePipe<IDefaultInNotificationsUnion<GValue>, GValue[]>

Definition​

Accumulates all values emitted using next Notifications, until complete is received. Then emit these values as an array.

You may provide:

  • onError: called when an error Notification is received. In this case the Observable never emits.
  • maxNumberOfValues: maximal size of the array containing the values (retains maxNumberOfValues last values).

Diagram​

Example​

Converts an observable of notifications to a simple Observable​

const subscribe = pipe$$(fromArrayWithNotifications([1, 2, 3, 4]), [
  notificationsToValues$$$<number>(),
]);

subscribe((values: number[]) => {
  console.log(values);
});

Output:

[1, 2, 3, 4]