risingwave_stream::executor

Trait Alias MessageStreamInner

source
trait MessageStreamInner<M> = Stream<Item = MessageStreamItemInner<M>> + Send;