Type Alias MessageBatch

pub type MessageBatch = MessageBatchInner<BarrierMutationType>;

Aliased Type§

pub enum MessageBatch {
    Chunk(StreamChunk),
    BarrierBatch(Vec<BarrierInner<Option<Arc<Mutation>>>>),
    Watermark(Watermark),
}