Struct BroadcastObserverHandle 

pub struct BroadcastObserverHandle { /* private fields */ }

Wraps a broadcast::Receiver<ProgressEvent> and implements the ObserverHandle trait defined in algocline-core.

Obtaining a handle is synchronous (broadcast::Sender::subscribe() does not perform I/O) and the handle is immediately valid — no pre-registered sink is required (Crux R3 / design-v1.md §5.4).

Trait Implementations

impl ObserverHandle for BroadcastObserverHandle

fn recv( &mut self, ) -> Pin<Box<dyn Future<Output = Result<ProgressEvent, ObserverRecvError>> + Send + '_>>

Await the next ProgressEvent from the broadcast channel.

• Returns Ok(event) on success.
• Returns Err(ObserverRecvError::Lagged(n)) when the receiver fell behind and n events were skipped; the next call resumes from the latest available event (no silent drop — the gap is reported).
• Returns Err(ObserverRecvError::Closed) when the sender is dropped (session terminated).

fn try_recv(&mut self) -> Result<ProgressEvent, ObserverRecvError>

Non-blocking receive.

Returns an event immediately if one is available, or an appropriate Err variant otherwise.

fn close(self: Box<Self>)

Consume and close this handle. After calling close the handle is dropped and no further events can be received.