ignore elements

latticexyz · Oct 23, 2024 · bd94747 · bd94747
1 parent a8f871a
commit bd94747
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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;