Skip to main content

setup_persistence_subscription

reth_bench::bench::persistence_waiter

Function setup_persistence_subscription 

Source 
pub(crate) async fn setup_persistence_subscription(
    ws_url: Url,
    persistence_timeout: Duration,
) -> Result<PersistenceSubscription>
Expand description

Establishes a websocket connection and subscribes to reth_subscribePersistedBlock.

The keepalive_interval is set to match persistence_timeout so that the WebSocket connection is not dropped during long MDBX commits that block the server from responding to pings.