Trait nakadion::consumer::LifecycleListener[−][src]

pub trait LifecycleListener: Send + 'static {
    fn on_consumer_started(&self, _subscription_id: SubscriptionId) { ... }

    fn on_consumer_stopped(&self, _subscription_id: SubscriptionId) { ... }

    fn on_stream_connected(
        &self, 
        _subscription_id: SubscriptionId, 
        _stream_id: StreamId
    ) { ... }

    fn on_stream_ended(
        &self, 
        _subscription_id: SubscriptionId, 
        _stream_id: StreamId
    ) { ... }
}

Provided methods

Implementors