From e0daafe7f79cbc6ef480aae332d37151350a5dd9 Mon Sep 17 00:00:00 2001
From: belopash <abelopashentsev@gmail.com>
Date: Mon, 30 Sep 2024 12:20:42 +0500
Subject: [PATCH] save

---
 test/tron-usdt/src/main.ts        | 2 +-
 tron/tron-data/src/data-source.ts | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/test/tron-usdt/src/main.ts b/test/tron-usdt/src/main.ts
index 937b7a04..7ee13ed7 100644
--- a/test/tron-usdt/src/main.ts
+++ b/test/tron-usdt/src/main.ts
@@ -14,7 +14,7 @@ const TOPIC0 = 'ddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef
 const dataSource = new DataSourceBuilder()
     .setGateway('https://v2.archive.subsquid.io/network/tron-mainnet')
     .setHttpApi({url: 'https://rpc.ankr.com/http/tron'})
-    .setBlockRange({from: 65659767})
+    .setBlockRange({from: 65677134})
     .addLog({
         where: {
             address: [CONTRACT],
diff --git a/tron/tron-data/src/data-source.ts b/tron/tron-data/src/data-source.ts
index 20b404a3..c899be1f 100644
--- a/tron/tron-data/src/data-source.ts
+++ b/tron/tron-data/src/data-source.ts
@@ -150,9 +150,10 @@ export class HttpDataSource {
                         }
                     })
 
-                    for await (let update of queue) {
+                    let update = queue.shift()
+                    while (update) {
                         yield update
-                        queue.shift()
+                        update = queue.shift()
                     }
 
                     break