Struct InMemoryTrajectorySink 

pub struct InMemoryTrajectorySink { /* private fields */ }

Simple Vec-backed sink. Useful for tests, eval harnesses that load the whole trajectory in memory, and the replay path.

Implementations

impl InMemoryTrajectorySink

pub fn new() -> Self

pub async fn snapshot(&self) -> Vec<TrajectoryRecord>

pub async fn len(&self) -> usize

pub async fn is_empty(&self) -> bool

Trait Implementations

impl Debug for InMemoryTrajectorySink

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

Formats the value using the given formatter.

impl Default for InMemoryTrajectorySink

fn default() -> InMemoryTrajectorySink

Returns the “default value” for a type.

impl TrajectorySink for InMemoryTrajectorySink

fn record<'life0, 'async_trait>( &'life0 self, record: TrajectoryRecord, ) -> Pin<Box<dyn Future<Output = Result<(), TrajectoryError>> + Send + 'async_trait>>

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