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