Revert "try piping watchLogs to queue scheduler"

This reverts commit ff56a0e.
latticexyz · Nov 12, 2024 · 510cc59 · 510cc59
1 parent c941317
commit 510cc59
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/packages/store-sync/src/createStoreSync.ts b/packages/store-sync/src/createStoreSync.ts
@@ -30,8 +30,6 @@ import {
   throwError,
   mergeWith,
   ignoreElements,
-  observeOn,
-  queueScheduler,
 } from "rxjs";
 import { debug as parentDebug } from "./debug";
 import { SyncStep } from "./SyncStep";
@@ -216,11 +214,7 @@ export async function createStoreSync({
   const pendingLogsWebSocketUrl = publicClient.chain?.rpcUrls?.wiresaw?.webSocket?.[0];
   const storedPendingLogs$ = pendingLogsWebSocketUrl
     ? startBlock$.pipe(
-        mergeMap((startBlock) =>
-          watchLogs({ url: pendingLogsWebSocketUrl, address, fromBlock: startBlock }).logs$.pipe(
-            observeOn(queueScheduler),
-          ),
-        ),
+        mergeMap((startBlock) => watchLogs({ url: pendingLogsWebSocketUrl, address, fromBlock: startBlock }).logs$),
         concatMap(async (block) => {
           await storageAdapter(block);
           return block;