Struct VecFeed 

pub struct VecFeed { /* private fields */ }

In-memory data feed backed by metadata-bearing market events.

Self::new retains the existing contract and does not sort its input. Self::from_feed_events sorts by (timestamp, series_rank, row_sequence).

Implementations

impl VecFeed

pub fn new(events: Vec<MarketEvent>) -> Self

Create a new feed from a pre-sorted vector of primary events.

pub fn from_feed_events(events: Vec<FeedEvent>) -> Self

Create a deterministically sorted feed from metadata-bearing events.

pub fn next_feed_event(&mut self) -> Option<FeedEvent>

Return the next event together with its ordering metadata.

pub fn peek_metadata(&self) -> Option<&EventMetadata>

Peek at the metadata for the next event without consuming it.

pub fn next_timestamp_batch(&mut self) -> Option<TimestampBatch>

Return all remaining events at the next timestamp.

pub fn remaining(&self) -> usize

Number of events remaining.

pub fn total(&self) -> usize

Total number of events in the feed (consumed + remaining).

pub fn reset(&mut self)

Reset the feed to the beginning.

Trait Implementations

impl Clone for VecFeed

fn clone(&self) -> VecFeed

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DataFeed for VecFeed

fn next_event(&mut self) -> Option<MarketEvent>

Return the next event, or None when the feed is exhausted.

fn peek(&self) -> Option<&MarketEvent>

Peek at the next event without consuming it.

fn next_batch(&mut self) -> Option<TimestampBatch>

Return all contiguous events at the next timestamp.

fn total_events(&self) -> Option<usize>

Total number of events when known without consuming the feed.

impl Debug for VecFeed

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

Formats the value using the given formatter.