Trait nakadion::components::committer::ProvidesCommitter

pub trait ProvidesCommitter {
    fn committer(
        &self, 
        subscription_id: SubscriptionId, 
        stream_id: StreamId
    ) -> Box<dyn Commits + Send + Sync + 'static>;
}

Gives a Commits

Required methods

fn committer(
    &self,
    subscription_id: SubscriptionId,
    stream_id: StreamId
) -> Box<dyn Commits + Send + Sync + 'static>

Loading content...

Implementors

impl<T> ProvidesCommitter for T where
    T: SubscriptionApi + Sync + Send + 'static + Clone, 

fn committer(
    &self,
    subscription_id: SubscriptionId,
    stream_id: StreamId
) -> Box<dyn Commits + Send + Sync + 'static>

Loading content...