Enum AlignedMessage

pub enum AlignedMessage {
    Barrier(Barrier),
    WatermarkLeft(Watermark),
    WatermarkRight(Watermark),
    Left(StreamChunk),
    Right(StreamChunk),
}

Variants

Barrier(Barrier)

WatermarkLeft(Watermark)

WatermarkRight(Watermark)

Left(StreamChunk)

Right(StreamChunk)

Implementations

impl AlignedMessage

pub fn is_barrier(&self) -> bool

Returns true if this is a AlignedMessage::Barrier, otherwise false

pub fn as_barrier_mut(&mut self) -> Option<&mut Barrier>

Optionally returns mutable references to the inner fields if this is a AlignedMessage::Barrier, otherwise None

pub fn as_barrier(&self) -> Option<&Barrier>

Optionally returns references to the inner fields if this is a AlignedMessage::Barrier, otherwise None

pub fn into_barrier(self) -> Result<Barrier, Self>

Returns the inner fields if this is a AlignedMessage::Barrier, otherwise returns back the enum in the Err case of the result

pub fn is_watermark_left(&self) -> bool

Returns true if this is a AlignedMessage::WatermarkLeft, otherwise false

pub fn as_watermark_left_mut(&mut self) -> Option<&mut Watermark>

Optionally returns mutable references to the inner fields if this is a AlignedMessage::WatermarkLeft, otherwise None

pub fn as_watermark_left(&self) -> Option<&Watermark>

Optionally returns references to the inner fields if this is a AlignedMessage::WatermarkLeft, otherwise None

pub fn into_watermark_left(self) -> Result<Watermark, Self>

Returns the inner fields if this is a AlignedMessage::WatermarkLeft, otherwise returns back the enum in the Err case of the result

pub fn is_watermark_right(&self) -> bool

Returns true if this is a AlignedMessage::WatermarkRight, otherwise false

pub fn as_watermark_right_mut(&mut self) -> Option<&mut Watermark>

Optionally returns mutable references to the inner fields if this is a AlignedMessage::WatermarkRight, otherwise None

pub fn as_watermark_right(&self) -> Option<&Watermark>

Optionally returns references to the inner fields if this is a AlignedMessage::WatermarkRight, otherwise None

pub fn into_watermark_right(self) -> Result<Watermark, Self>

Returns the inner fields if this is a AlignedMessage::WatermarkRight, otherwise returns back the enum in the Err case of the result

pub fn is_left(&self) -> bool

Returns true if this is a AlignedMessage::Left, otherwise false

pub fn as_left_mut(&mut self) -> Option<&mut StreamChunk>

Optionally returns mutable references to the inner fields if this is a AlignedMessage::Left, otherwise None

pub fn as_left(&self) -> Option<&StreamChunk>

Optionally returns references to the inner fields if this is a AlignedMessage::Left, otherwise None

pub fn into_left(self) -> Result<StreamChunk, Self>

Returns the inner fields if this is a AlignedMessage::Left, otherwise returns back the enum in the Err case of the result

pub fn is_right(&self) -> bool

Returns true if this is a AlignedMessage::Right, otherwise false

pub fn as_right_mut(&mut self) -> Option<&mut StreamChunk>

Optionally returns mutable references to the inner fields if this is a AlignedMessage::Right, otherwise None

pub fn as_right(&self) -> Option<&StreamChunk>

Optionally returns references to the inner fields if this is a AlignedMessage::Right, otherwise None

pub fn into_right(self) -> Result<StreamChunk, Self>

Returns the inner fields if this is a AlignedMessage::Right, otherwise returns back the enum in the Err case of the result

Trait Implementations

impl Debug for AlignedMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for AlignedMessage

fn eq(&self, other: &AlignedMessage) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for AlignedMessage