Struct GatInMemoryStreamRepository 

pub struct GatInMemoryStreamRepository { /* private fields */ }

GAT-based in-memory implementation of StreamRepositoryGat

Implementations

impl GatInMemoryStreamRepository

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 GatInMemoryStreamRepository

fn clone(&self) -> GatInMemoryStreamRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GatInMemoryStreamRepository

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

Formats the value using the given formatter.

impl Default for GatInMemoryStreamRepository

fn default() -> Self

Returns the “default value” for a type.

impl StreamRepositoryGat for GatInMemoryStreamRepository

type FindSessionFuture<'a> = impl Future<Output = Result<Option<StreamSession>, DomainError>> + Send + 'a where Self: 'a

Future type for finding sessions

type SaveSessionFuture<'a> = impl Future<Output = Result<(), DomainError>> + Send + 'a where Self: 'a

Future type for saving sessions

type RemoveSessionFuture<'a> = impl Future<Output = Result<(), DomainError>> + Send + 'a where Self: 'a

Future type for removing sessions

type FindActiveSessionsFuture<'a> = impl Future<Output = Result<Vec<StreamSession>, DomainError>> + Send + 'a where Self: 'a

Future type for finding active sessions

fn find_session(&self, session_id: SessionId) -> Self::FindSessionFuture<'_>

Find session by ID

fn save_session(&self, session: StreamSession) -> Self::SaveSessionFuture<'_>

Save session (insert or update)

fn remove_session(&self, session_id: SessionId) -> Self::RemoveSessionFuture<'_>

Remove session

fn find_active_sessions(&self) -> Self::FindActiveSessionsFuture<'_>

Find all active sessions