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