risingwave_stream::executor

Type Alias MessageStreamItemInner

source
pub type MessageStreamItemInner<M> = StreamExecutorResult<MessageInner<M>>;

Aliased Type§

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

Variants§

§1.0.0

Ok(MessageInner<M>)

Contains the success value

§1.0.0

Err(StreamExecutorError)

Contains the error value