Enum ConcurrencyDecision 

pub enum ConcurrencyDecision {
    InterruptAndStartNew,
    Reject {
        reason: String,
    },
    Queue,
    Parallel,
    MergeIntoRunning,
}

Decision on how to handle concurrent interactions

Variants

InterruptAndStartNew

Interrupt the current interaction and start a new one

Reject

Reject the new input

Fields

reason: String

Reason for rejection

Queue

Queue the new input for later processing

Parallel

Run in parallel with the current interaction

MergeIntoRunning

Merge the new input into the running interaction

Implementations

impl ConcurrencyDecision

pub fn reject(reason: impl Into<String>) -> Self

Create a reject decision

Trait Implementations

impl Clone for ConcurrencyDecision

fn clone(&self) -> ConcurrencyDecision

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConcurrencyDecision

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for ConcurrencyDecision

impl PartialEq for ConcurrencyDecision

fn eq(&self, other: &ConcurrencyDecision) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ConcurrencyDecision