Struct GatInMemoryStreamStore 

pub struct GatInMemoryStreamStore { /* private fields */ }

GAT-based in-memory implementation of StreamStoreGat

Implementations

impl GatInMemoryStreamStore

pub fn new() -> Self

pub fn stream_count(&self) -> usize

Get number of stored streams

pub fn clear(&self)

Clear all streams (for testing)

pub fn all_stream_ids(&self) -> Vec<StreamId>

Get all stream IDs (for testing)

Trait Implementations

impl Clone for GatInMemoryStreamStore

fn clone(&self) -> GatInMemoryStreamStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GatInMemoryStreamStore

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

Formats the value using the given formatter.

impl Default for GatInMemoryStreamStore

fn default() -> Self

Returns the “default value” for a type.

impl StreamStoreGat for GatInMemoryStreamStore

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

Future type for storing streams

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

Future type for getting streams

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

Future type for deleting streams

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

Future type for listing streams

fn store_stream(&self, stream: Stream) -> Self::StoreStreamFuture<'_>

Store a stream

fn get_stream(&self, stream_id: StreamId) -> Self::GetStreamFuture<'_>

Retrieve stream by ID

fn delete_stream(&self, stream_id: StreamId) -> Self::DeleteStreamFuture<'_>

Delete stream

fn list_streams_for_session( &self, session_id: SessionId, ) -> Self::ListStreamsFuture<'_>

List streams for session