skipUntil<S> method

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

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

Example

MergeStream([
    Stream.fromIterable([1]),
    TimerStream(2, Duration(minutes: 2))
  ])
  .skipUntil(TimerStream(true, Duration(minutes: 1)))
  .listen(print); // prints 2;

Implementation

Stream<T> skipUntil<S>(Stream<S> otherStream) =>
    SkipUntilStreamTransformer<T, S>(otherStream).bind(this);