Module branch
timely::dataflow::operators
Operators that separate one stream into two streams based on some condition
Extension trait for Stream.
Stream