Type Alias DesiredStreams 

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

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

Aliased Type

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

Fields

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

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