[−][src]Trait nakadion::consumer::LifecycleListener
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
)
&self,
_subscription_id: SubscriptionId,
_stream_id: StreamId
)
fn on_stream_ended(
&self,
_subscription_id: SubscriptionId,
_stream_id: StreamId
)
&self,
_subscription_id: SubscriptionId,
_stream_id: StreamId
)