Struct NStreamsHandler 

pub struct NStreamsHandler<S, R> { /* private fields */ }

Coordinates read-side subscriptions with history replay and live tailing.

Implementations

impl<S, R> NStreamsHandler<S, R>

where S: EventStore + 'static, R: ReadStreamBackend + 'static,

pub fn new(store: S, read_stream: R) -> Self

pub fn with_max_event_bytes( store: S, read_stream: R, max_event_bytes: u64, ) -> Self

pub async fn subscribe<N: Namespace>( &self, namespace: &N, history_count: u64, ) -> Result<Subscription>

Subscribe to a namespace, replaying up to history_count events before live tail.

pub async fn is_read_stream_ready<N: Namespace>(&self, namespace: &N) -> bool

Trait Implementations

impl<S, R> Clone for NStreamsHandler<S, R>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.