Type Alias DesiredStreams 

type DesiredStreams<'s> = OkErr<StreamVec<'s, Timestamp, (Row, Timestamp, Diff)>, StreamVec<'s, Timestamp, (DataflowError, Timestamp, Diff)>>;

Type of the desired stream, split into Ok and Err streams.

Aliased Type

struct DesiredStreams<'s> {
    ok: Stream<'s, Timestamp, Vec<(Row, Timestamp, Overflowing<i64>)>>,
    err: Stream<'s, Timestamp, Vec<(DataflowError, Timestamp, Overflowing<i64>)>>,
}

Fields

ok: Stream<'s, Timestamp, Vec<(Row, Timestamp, Overflowing<i64>)>>

err: Stream<'s, Timestamp, Vec<(DataflowError, Timestamp, Overflowing<i64>)>>