observingElement<T> function

StreamPredicate<T> observingElement<T>(
  1. T e
)

Implementation

StreamPredicate<T> observingElement<T>(T e) => (StreamElement o) => e == o.elem;