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.