risingwave_stream::executor

Type Alias DispatcherMessageStreamItem

source 
pub type DispatcherMessageStreamItem = StreamExecutorResult<DispatcherMessage>;

Aliased Type§

enum DispatcherMessageStreamItem {
    Ok(MessageInner<()>),
    Err(StreamExecutorError),
}

Variants§

§1.0.0

Ok(MessageInner<()>)

Contains the success value

§1.0.0

Err(StreamExecutorError)

Contains the error value