Struct InMemorySeqStore 

pub struct InMemorySeqStore { /* private fields */ }

In-memory FixSeqStore backed by atomics. Counters start at 1, matching the FIX convention that the first message of a session carries MsgSeqNum=1.

Implementations

impl InMemorySeqStore

pub fn new() -> Self

A fresh store with both counters at 1.

pub fn with_counters(next_out: u64, next_in: u64) -> Self

A store seeded with explicit counters — useful for simulating recovery after a reconnect where the previous session left off mid-stream.

Trait Implementations

impl Debug for InMemorySeqStore

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

Formats the value using the given formatter.

impl Default for InMemorySeqStore

fn default() -> Self

Returns the “default value” for a type.

impl FixSeqStore for InMemorySeqStore

fn next_out<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = u64> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The next outbound MsgSeqNum, advancing the counter.

fn peek_out<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = u64> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Peek the next outbound MsgSeqNum without advancing (for building a resend range or diagnostics).

fn observed_in<'life0, 'async_trait>( &'life0 self, n: u64, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Record that an inbound message with MsgSeqNum == n was processed.

fn current_in<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = u64> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The next expected inbound MsgSeqNum (one past the highest observed).

fn reset<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reset both counters to 1 (next outbound = 1, next expected inbound = 1).