pub struct RejectWhenBusyConcurrencyPolicy;Expand description
Reject policy: Reject new inputs when busy
Trait Implementations§
Source§impl ConcurrencyPolicy for RejectWhenBusyConcurrencyPolicy
impl ConcurrencyPolicy for RejectWhenBusyConcurrencyPolicy
Source§fn decide(
&self,
running: &RunningState,
_new_event: &Event,
) -> ConcurrencyDecision
fn decide( &self, running: &RunningState, _new_event: &Event, ) -> ConcurrencyDecision
Decide how to handle a new event given the current running state
Auto Trait Implementations§
impl Freeze for RejectWhenBusyConcurrencyPolicy
impl RefUnwindSafe for RejectWhenBusyConcurrencyPolicy
impl Send for RejectWhenBusyConcurrencyPolicy
impl Sync for RejectWhenBusyConcurrencyPolicy
impl Unpin for RejectWhenBusyConcurrencyPolicy
impl UnsafeUnpin for RejectWhenBusyConcurrencyPolicy
impl UnwindSafe for RejectWhenBusyConcurrencyPolicy
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more