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

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

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

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

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

Provided methods

pub fn on_consumer_started(&self, _subscription_id: SubscriptionId)[src]

pub fn on_consumer_stopped(&self, _subscription_id: SubscriptionId)[src]

pub fn on_stream_connected(
    &self,
    _subscription_id: SubscriptionId,
    _stream_id: StreamId
)[src]

pub fn on_stream_ended(
    &self,
    _subscription_id: SubscriptionId,
    _stream_id: StreamId
)[src]

Loading content...

Implementors

Loading content...