timely::dataflow::operators::core

Module ok_err

Source
Expand description

Operators that separate one stream into two streams based on some condition

Traitsยง

OkErr
Extension trait for Stream.