skipUntil method

Stream<T> skipUntil(
  1. bool predicate(
    1. T
    )
)

Discards events until predicate returns true, then emits all subsequent ones.

Implementation

Stream<T> skipUntil(bool Function(T) predicate) async* {
  var triggered = false;
  await for (final value in this) {
    if (!triggered && predicate(value)) triggered = true;
    if (triggered) yield value;
  }
}