Struct MultiStreamJoinResult 

pub struct MultiStreamJoinResult {
    pub events: Vec<StreamEvent>,
    pub join_timestamp: SystemTime,
}

Result of multi-stream join (supports 2+ streams)

Fields

events: Vec<StreamEvent>

All events that participated in the join (ordered)

join_timestamp: SystemTime

Timestamp when join was completed

Implementations

impl MultiStreamJoinResult

pub fn from_two_events( left: StreamEvent, right: StreamEvent, timestamp: SystemTime, ) -> Self

Create from two events (basic 2-stream join)

pub fn from_result_and_event( result: MultiStreamJoinResult, event: StreamEvent, timestamp: SystemTime, ) -> Self

Create from existing result + new event (nested join)

pub fn get_event(&self, index: usize) -> Option<&StreamEvent>

Get event by index

pub fn left_event(&self) -> &StreamEvent

Get first event (for backward compatibility)

pub fn right_event(&self) -> &StreamEvent

Get second event (for backward compatibility)

Trait Implementations

impl Clone for MultiStreamJoinResult

fn clone(&self) -> MultiStreamJoinResult

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MultiStreamJoinResult

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

Formats the value using the given formatter.