Struct JoinEventRx 

pub struct JoinEventRx { /* private fields */ }

Receiver for join trigger events.

Obtained as the first argument to the JoinBuilder::on_triggers closure. Call .recv().await in a loop to consume trigger events from all input forwarders. Returns Err when all input forwarders have exited and the channel is closed.

Implementations

impl JoinEventRx

pub async fn recv(&mut self) -> ExecutorResult<JoinTrigger>

Receive the next trigger event.

Returns Ok(JoinTrigger) when an input fires, or Err when all input forwarders have dropped their senders — on every runtime, ending any while let Ok(_) = rx.recv().await loop.