pub type DispatcherMessage = MessageInner<()>;Aliased Type§
pub enum DispatcherMessage {
Chunk(StreamChunk),
Barrier(BarrierInner<()>),
Watermark(Watermark),
}pub type DispatcherMessage = MessageInner<()>;pub enum DispatcherMessage {
Chunk(StreamChunk),
Barrier(BarrierInner<()>),
Watermark(Watermark),
}