Struct InMemoryStreamRepository

pub struct InMemoryStreamRepository { /* private fields */ }

In-memory implementation of StreamRepository

Implementations

impl InMemoryStreamRepository

pub fn new() -> Self

pub fn session_count(&self) -> usize

Get number of stored sessions

pub fn clear(&self)

Clear all sessions (for testing)

pub fn all_session_ids(&self) -> Vec<SessionId>

Get all session IDs (for testing)

Trait Implementations

impl Clone for InMemoryStreamRepository

fn clone(&self) -> InMemoryStreamRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryStreamRepository

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

Formats the value using the given formatter.

impl Default for InMemoryStreamRepository

fn default() -> Self

Returns the “default value” for a type.

impl StreamRepository for InMemoryStreamRepository

fn find_session<'life0, 'async_trait>( &'life0 self, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = DomainResult<Option<StreamSession>>> + Send + 'async_trait>>

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

Find session by ID

fn save_session<'life0, 'async_trait>( &'life0 self, session: StreamSession, ) -> Pin<Box<dyn Future<Output = DomainResult<()>> + Send + 'async_trait>>

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

Save session (insert or update)

fn remove_session<'life0, 'async_trait>( &'life0 self, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = DomainResult<()>> + Send + 'async_trait>>

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

Remove session

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

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

Find all active sessions