Struct RobustSubscription 

pub struct RobustSubscription<N: Network> { /* private fields */ }

A robust subscription wrapper that automatically handles provider failover and periodic reconnection attempts to the primary provider.

Implementations

impl<N: Network> RobustSubscription<N>

pub async fn recv(&mut self) -> Result<N::HeaderResponse, Error>

Receive the next item from the subscription with automatic failover.

This method will:

• Attempt to receive from the current subscription (WebSocket or HTTP polling)
• Handle errors by switching to fallback providers
• Periodically attempt to reconnect to the primary provider
• Will switch to fallback providers if subscription timeout is exhausted

Primary Provider Reconnection

The primary provider is retried in two scenarios:

1. Periodic reconnection: Every reconnect_interval (default: 30 seconds) while on a fallback provider and successfully receiving blocks. Note: The actual reconnection attempt occurs when a new block is received, so if blocks arrive slower than the reconnect interval, reconnection will be delayed until the next block.
2. Fallback failure: Immediately when a fallback provider fails, before attempting the next fallback provider

Errors

• Propagates any underlying subscription errors.
• If all providers have been exhausted and failed, returns the last attempt’s error.

pub fn is_empty(&self) -> bool

Check if the subscription channel is empty (no pending messages)

pub fn into_stream(self) -> RobustSubscriptionStream<N>

Convert the subscription into a stream.

Trait Implementations

impl<N: Debug + Network> Debug for RobustSubscription<N>

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

Formats the value using the given formatter.

impl<N: 'static + Clone + Send + Network> From<RobustSubscription<N>> for RobustSubscriptionStream<N>

fn from(recv: RobustSubscription<N>) -> Self

Converts to this type from the input type.