skipUntil<S> method

Observable<T> skipUntil<S>(
  1. Stream<S> otherStream
)

Starts emitting items only after the given stream emits an item.

Example

new Observable.merge([
    new Observable.just(1),
    new Observable.timer(2, new Duration(minutes: 2))
  ])
  .skipUntil(new Observable.timer(true, new Duration(minutes: 1)))
  .listen(print); // prints 2;

Implementation

Observable<T> skipUntil<S>(Stream<S> otherStream) =>
    transform(SkipUntilStreamTransformer<T, S>(otherStream));