Struct WithTimes 

pub struct WithTimes<E, L> { /* private fields */ }

Implementations

impl<E, L> WithTimes<E, L>

pub fn new(times: usize, listener: L) -> Self

Trait Implementations

impl<E, L> Listener for WithTimes<E, L>

where E: Event, L: Listener<Event = E>,

type Event = E

The event type expected by this Listener.

async fn begin(&mut self, cancel: &CancellationToken)

Called when the listener starts up.

async fn handle( &mut self, cancel: &CancellationToken, event: Guard<Self::Event>, )

Processes a single received event.

async fn after(&mut self, cannel: &CancellationToken)

Called when the listener exits (whether due to cancellation, stream end, or error).