Struct StartupReceiver 

pub struct StartupReceiver { /* private fields */ }

Receiver half of the consumer startup handshake. Resolves once the consumer calls ConsumerContext::mark_ready (Ok) or its start() returns an Err first (Err).

For ConsumerStartupMode::Immediate consumers the receiver is pre-resolved at construction time (see StartupReceiver::immediate).

Implementations

impl StartupReceiver

pub fn immediate() -> Self

Construct a receiver that is already resolved as Ok. Used for ConsumerStartupMode::Immediate consumers so the controller can uniformly await every receiver without changing behaviour.

pub async fn await_ready(self) -> Result<(), CamelError>

Wait for the consumer to become ready or fail. Resolves:

• Ok(()) if the consumer signalled readiness.
• Err(CamelError::RouteError(_)) if the consumer’s start() returned an error before signalling readiness.
• Err(CamelError::RouteError(_)) if the signal sender was dropped without either transition (programming-contract violation).

Trait Implementations

impl Debug for StartupReceiver

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

Formats the value using the given formatter.