Struct BufferedRecorder

pub struct BufferedRecorder<E, R>
where
    E: Env,
    R: ReplayBufferBase,
{ /* private fields */ }

A recorder that buffers sequences of observations and actions in memory.

The BufferedRecorder is designed to temporarily store sequences of environment interactions during evaluation runs. This is particularly useful for analyzing agent behavior, debugging policies, or collecting demonstration data.

Type Parameters

• E - The environment type that implements the Env trait
• R - The replay buffer type that implements the ReplayBufferBase trait

Implementations

impl<E, R> BufferedRecorder<E, R>

where E: Env, R: ReplayBufferBase,

pub fn new() -> Self

Creates a new empty buffered recorder.

Returns

A new instance of BufferedRecorder with an empty buffer.

pub fn iter(&self) -> Iter<'_, Record>

Returns an iterator over the recorded data.

This method allows you to iterate over all records stored in the buffer without consuming them.

Returns

An iterator over references to the Records in the buffer.

Trait Implementations

impl<E, R> Default for BufferedRecorder<E, R>

where E: Env + Default, R: ReplayBufferBase + Default,

fn default() -> BufferedRecorder<E, R>

Returns the “default value” for a type.

impl<E, R> Recorder<E, R> for BufferedRecorder<E, R>

where E: Env, R: ReplayBufferBase,

fn write(&mut self, record: Record)

Writes a Record to the internal buffer.

This method appends the given record to the end of the buffer. The records maintain their insertion order, which is important for sequential data analysis.

Arguments

• record - The record to be stored in the buffer

Note

This method is currently private as part of the Recorder trait implementation. Future versions may make it public if there’s a need for direct record insertion.

fn flush(&mut self, _step: i64)

Flushes the buffered data at the specified step.

This method is currently unimplemented as the buffered recorder is designed to hold all data in memory until explicitly processed.

Arguments

• _step - The step at which to flush the buffer

Panics

This method will panic if called, as it is not implemented.

fn store(&mut self, _record: Record)

Stores a record in the underlying storage system.

This method is currently unimplemented as the buffered recorder only supports in-memory storage.

Arguments

• _record - The record to be stored

Panics

This method will panic if called, as it is not implemented.

fn save_model(&self, base: &Path, agent: &Box<dyn Agent<E, R>>) -> Result<()>

Saves the current state of the agent’s model.

fn load_model( &self, base: &Path, agent: &mut Box<dyn Agent<E, R>>, ) -> Result<()>

Loads a previously saved model state into the agent.