Enum ConsumerStartupMode 

pub enum ConsumerStartupMode {
    Immediate,
    Explicit,
}

Declares when the runtime may consider a Consumer “started”.

Immediate (default) preserves the classic fire-and-forget semantics: spawn_consumer_task returns as soon as the consumer task is spawned, matching the behaviour of timer, file, direct and similar polling consumers whose start() IS the lifetime loop.

Explicit is for resource-binding consumers (HTTP, WebSocket, …) whose start() returns control only after the resource (e.g. TcpListener) is bound and ready. The consumer MUST call ConsumerContext::mark_ready after a successful bind so the runtime can await readiness and propagate pre-ready start() errors as proper startup failures.

Adding this as a default-returning trait method keeps every existing Consumer impl backward compatible.

Variants

Immediate

Consumer’s start() IS the lifetime loop. The runtime treats the consumer as ready the moment start() is invoked. (Default)

Explicit

Consumer binds/registers a resource inside start() and signals readiness explicitly via ConsumerContext::mark_ready().

Trait Implementations

impl Clone for ConsumerStartupMode

fn clone(&self) -> ConsumerStartupMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ConsumerStartupMode

impl Debug for ConsumerStartupMode

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

Formats the value using the given formatter.

impl Default for ConsumerStartupMode

fn default() -> ConsumerStartupMode

Returns the “default value” for a type.

impl Eq for ConsumerStartupMode

impl PartialEq for ConsumerStartupMode

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ConsumerStartupMode