Struct StreamState 

pub struct StreamState<L> {
    pub log: Arc<L>,
    pub notifier: Arc<dyn StreamNotifier>,
}

State for a stream-only service.

Fields

log: Arc<L>

Backend used to load committed batches.

notifier: Arc<dyn StreamNotifier>

In-process notifier used to wake subscribers after new batches commit.

Implementations

impl<L> StreamState<L>

where L: Log,

pub fn new(log: Arc<L>, notifier: Arc<dyn StreamNotifier>) -> Self

Trait Implementations

impl<L> Clone for StreamState<L>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E> From<AppState<E>> for StreamState<E>

fn from(state: AppState<E>) -> Self

Converts to this type from the input type.