function stable

Returns an Observable that skips items emitted by the source Observable until a second Observable emits an item.

skipUntil<T>(notifier: Observable<any>): MonoTypeOperatorFunction<T>



The second Observable that has to emit an item before the source Observable's elements begin to be mirrored by the resulting Observable.


MonoTypeOperatorFunction<T>: An Observable that skips items from the source Observable until the second Observable emits an item, then emits the remaining items.


The skipUntil operator causes the observable stream to skip the emission of values ​​until the passed in observable emits the first value. This can be particularly useful in combination with user interactions, responses of http requests or waiting for specific times to pass by.

skipUntil marble diagram

Internally the skipUntil operator subscribes to the passed in observable (in the following called notifier) in order to recognize the emission of its first value. When this happens, the operator unsubscribes from the notifier and starts emitting the values of the source observable. It will never let the source observable emit any values if the notifier completes or throws an error without emitting a value before.


In the following example, all emitted values ​​of the interval observable are skipped until the user clicks anywhere within the page.

import { interval, fromEvent } from 'rxjs';
import { skipUntil } from 'rxjs/operators';

const intervalObservable = interval(1000);
const click = fromEvent(document, 'click');

const emitAfterClick = intervalObservable.pipe(
// clicked at 4.6s. output: 5...6...7...8........ or
// clicked at 7.3s. output: 8...9...10..11.......
const subscribe = emitAfterClick.subscribe(value => console.log(value));

© 2015–2018 Google, Inc., Netflix, Inc., Microsoft Corp. and contributors.
Code licensed under an Apache-2.0 License. Documentation licensed under CC BY 4.0.