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

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

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
)

Loading content...

Implementors

Loading content...