diff --git a/packages/store-sync/src/createStoreSync.ts b/packages/store-sync/src/createStoreSync.ts index fbd0683480..829b59261e 100644 --- a/packages/store-sync/src/createStoreSync.ts +++ b/packages/store-sync/src/createStoreSync.ts @@ -26,6 +26,7 @@ import { combineLatest, scan, identity, + retry, } from "rxjs"; import { debug as parentDebug } from "./debug"; import { SyncStep } from "./SyncStep"; @@ -184,6 +185,10 @@ export async function createStoreSync( tap((blockNumber) => { debug("on block number", blockNumber, "for", followBlockTag, "block tag"); }), + retry({ + count: undefined, // ie unlimited + delay: 3000, // poll the RPC every 3 seconds + }), shareReplay(1), );