Type Alias Message

pub type Message = MessageInner<BarrierMutationType>;

Aliased Type

enum Message {
    Chunk(StreamChunk),
    Barrier(BarrierInner<Option<Arc<Mutation>>>),
    Watermark(Watermark),
}

Variants

Chunk(StreamChunk)

Barrier(BarrierInner<Option<Arc<Mutation>>>)

Watermark(Watermark)

Trait Implementations

impl From<StreamChunk> for Message

fn from(chunk: StreamChunk) -> Self

Converts to this type from the input type.