pub type DispatcherMessageBatch = MessageBatchInner<()>;Aliased Type§
pub enum DispatcherMessageBatch {
Chunk(StreamChunk),
BarrierBatch(Vec<BarrierInner<()>>),
Watermark(Watermark),
}pub type DispatcherMessageBatch = MessageBatchInner<()>;pub enum DispatcherMessageBatch {
Chunk(StreamChunk),
BarrierBatch(Vec<BarrierInner<()>>),
Watermark(Watermark),
}