Struct re_sdk::sink::MemorySinkStorage

pub struct MemorySinkStorage {
    inner: Arc<Mutex<MemorySinkStorageInner>>,
    pub(crate) rec: RecordingStream,
}

The storage used by MemorySink.

Fields

inner: Arc<Mutex<MemorySinkStorageInner>>

rec: RecordingStream

Implementations

impl MemorySinkStorage

fn new(rec: RecordingStream) -> Self

Create a new MemorySinkStorage with an associated RecordingStream.

fn write(&self) -> MappedMutexGuard<'_, Vec<LogMsg>>

Write access to the inner array of LogMsg.

pub fn num_msgs(&self) -> usize

How many messages are currently written to this memory sink

This automatically takes care of flushing the underlying crate::RecordingStream.

pub fn take(&self) -> Vec<LogMsg>

Consumes and returns the inner array of LogMsg.

This automatically takes care of flushing the underlying crate::RecordingStream.

pub fn concat_memory_sinks_as_bytes( sinks: &[&Self] ) -> Result<Vec<u8>, EncodeError>

Convert the stored messages into an in-memory Rerun log file.

This automatically takes care of flushing the underlying crate::RecordingStream.

pub fn drain_as_bytes(&self) -> Result<Vec<u8>, EncodeError>

Drain the stored messages and return them as an in-memory RRD.

This automatically takes care of flushing the underlying crate::RecordingStream.

pub fn store_id(&self) -> Option<StoreId>

Get the StoreId from the associated RecordingStream if it exists.

Trait Implementations

impl Clone for MemorySinkStorage

fn clone(&self) -> MemorySinkStorage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Drop for MemorySinkStorage

fn drop(&mut self)

Executes the destructor for this type.