where method

LxStream<T> where(
  1. bool test(
    1. T event
    )
)

Filters events based on test.

Implementation

LxStream<T> where(bool Function(T event) test) {
  return LxStream<T>.defer(() => valueStream.where(test));
}