TakeUntilExtension<T> extension

Extends the Stream class with the ability receive events from the source Stream until another Stream produces a value.

on
  • Stream<T>

Methods

takeUntil<S>(Stream<S> otherStream) → Stream<T>
Returns the values from the source Stream sequence until the other Stream sequence produces a value. [...]