Method stream

crates/shared/src/current_block.rs:42–59

(
        &self,
        http_url: Url,
        alloy_provider: AlloyProvider,
    )

    const BLOCK_POLL_INTERVAL: Duration = Duration::from_millis(500);

    pub async fn stream(
        &self,
        http_url: Url,
        alloy_provider: AlloyProvider,
    ) -> Result<CurrentBlockWatcher> {
        match &self.node_ws_url {
            Some(ws_url) => current_block_ws_stream(alloy_provider, ws_url.clone()).await,
            #[allow(deprecated)]
            None => {
                current_block_stream(
                    http_url,
                    self.block_stream_poll_interval
                        .unwrap_or(Self::BLOCK_POLL_INTERVAL),
                )
                .await
            }
        }
    }
}

impl From<&configs::shared::CurrentBlockConfig> for Arguments {