From bd9474792bd7c645fa82969230864db610470c9a Mon Sep 17 00:00:00 2001 From: Kevin Ingersoll Date: Wed, 23 Oct 2024 11:01:10 +0100 Subject: [PATCH] ignore elements --- packages/store-sync/src/createStoreSync.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/store-sync/src/createStoreSync.ts b/packages/store-sync/src/createStoreSync.ts index 5e4a57ffdf..b152661591 100644 --- a/packages/store-sync/src/createStoreSync.ts +++ b/packages/store-sync/src/createStoreSync.ts @@ -29,7 +29,7 @@ import { mergeMap, throwError, mergeWith, - EMPTY, + ignoreElements, } from "rxjs"; import { debug as parentDebug } from "./debug"; import { SyncStep } from "./SyncStep"; @@ -286,7 +286,7 @@ export async function createStoreSync({ }), // subscribe to `latestBlockNumber$` so the sync progress is updated // but don't merge/emit anything - mergeWith(latestBlockNumber$.pipe(mergeMap(() => EMPTY))), + mergeWith(latestBlockNumber$.pipe(ignoreElements())), tap(async ({ logs, blockNumber }) => { debug("stored", logs.length, "logs for block", blockNumber); lastBlockNumberProcessed = blockNumber;