pub type MessageStreamItem = MessageStreamItemInner<BarrierMutationType>;
Aliased Type§
enum MessageStreamItem {
Ok(MessageInner<Option<Arc<Mutation>>>),
Err(StreamExecutorError),
}
Variants§
Ok(MessageInner<Option<Arc<Mutation>>>)
Contains the success value
Err(StreamExecutorError)
Contains the error value