Struct StreamItem 

pub struct StreamItem { /* private fields */ }

One unit of flow through the spine: a packet plus its clock-domain ticks.

Couples a StreamPacket payload with the Ticks observed at it, so a packet carries its clock-domain context as it moves through the stream. An item can be projected into a runtime Value, a SequenceItem, or a sequenced packet Event.

Implementations

impl StreamItem

pub fn new(packet: StreamPacket) -> Self

Creates an item carrying packet with no ticks.

pub fn with_ticks(packet: StreamPacket, ticks: Vec<Tick>) -> Result<Self>

Creates an item carrying packet with ticks, validating the ticks.

Returns an error if ticks is not a valid clock-domain reading.

pub fn packet(&self) -> &StreamPacket

Returns the packet payload.

pub fn ticks(&self) -> &[Tick]

Returns the clock-domain ticks observed at this item.

pub fn packet_value(&self, cx: &mut Cx) -> Result<Value>

Materializes the packet payload as a runtime Value.

pub fn sequence_item(&self, cx: &mut Cx) -> Result<SequenceItem>

Projects this item into a SequenceItem, preserving its ticks.

pub fn chunk_event(&self, cx: &mut Cx, run: Ref, seq: u64) -> Result<Event>

Builds a sequenced packet Event for run at sequence number seq.

Trait Implementations

impl Clone for StreamItem

fn clone(&self) -> StreamItem

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamItem

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

Formats the value using the given formatter.

impl Eq for StreamItem

impl PartialEq for StreamItem

fn eq(&self, other: &StreamItem) -> 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 StreamItem