Struct Recording 

pub struct Recording<S> { /* private fields */ }

A thread-safe recording of stream items with optional capacity limits.

Recording stores items with their timing information and can be shared across threads. It supports bounded or unbounded storage.

Implementations

impl<S> Recording<S>

pub fn new() -> Self

Creates a new unbounded recording.

pub fn from_items(items: impl IntoIterator<Item = RecordedItem<S>>) -> Self

Creates a recording from a sequence of recorded items.

pub fn from_raw_items(items: impl IntoIterator<Item = S>) -> Self

Creates a recording from a sequence of items.

pub fn with_capacity(capacity: usize) -> Self

Creates a recording that keeps only the last capacity items. Older items are dropped as new ones arrive.

pub async fn save(&self, path: impl AsRef<Path>) -> Result<()>

where S: Serialize,

Saves the recording to disk with timing information.

pub async fn load(path: impl AsRef<Path>) -> Result<Self>

where S: for<'de> Deserialize<'de>,

Loads a recording from disk.

impl<S: Clone> Recording<S>

pub fn items(&self) -> Vec<S>

Returns the items in the recording.

pub fn replay(&self) -> impl Stream<Item = S>

Replays items with original timing delays between them.

pub fn replay_from(&self, start_seq: u64) -> impl Stream<Item = S>

Replays items starting from sequence number start_seq. Timing between replayed items is preserved.

pub fn replay_since(&self, since: SystemTime) -> impl Stream<Item = S>

Replays items recorded after since. Timing between replayed items is preserved.

pub fn replay_range(&self, start: u64, end: u64) -> impl Stream<Item = S>

Replays items within the sequence range [start, end] (inclusive). Timing between replayed items is preserved.

pub fn replay_with_speed(&self, speed: Speed) -> impl Stream<Item = S>

Replays with adjusted timing. Speed of 2.0 is twice as fast, 0.5 is half the speed. Relative timing between replayed items is preserved.

pub fn replay_immediate(&self) -> impl Stream<Item = S>

Replays items immediately without any delays. Useful for tests that don’t care about timing.

Trait Implementations

impl<S: Clone> Clone for Recording<S>

fn clone(&self) -> Recording<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for Recording<S>

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

Formats the value using the given formatter.

impl<S> Default for Recording<S>

fn default() -> Self

Returns the “default value” for a type.

impl<'de, S> Deserialize<'de> for Recording<S>

where S: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<S> Serialize for Recording<S>

where S: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.