From 90ad0b808ed424f3b9cd45a7d6ab32c4561fb6b1 Mon Sep 17 00:00:00 2001
From: arobsn <87387688+arobsn@users.noreply.github.com>
Date: Fri, 6 Sep 2024 19:36:42 -0300
Subject: [PATCH] fix return types of stream methods

---
 .changeset/late-pumpkins-raise.md                           | 5 +++++
 .../src/ergo-graphql/ergoGraphQLProvider.ts                 | 4 ++--
 .../blockchain-providers/src/types/blockchainProvider.ts    | 6 +++---
 3 files changed, 10 insertions(+), 5 deletions(-)
 create mode 100644 .changeset/late-pumpkins-raise.md

diff --git a/.changeset/late-pumpkins-raise.md b/.changeset/late-pumpkins-raise.md
new file mode 100644
index 0000000..3df1de7
--- /dev/null
+++ b/.changeset/late-pumpkins-raise.md
@@ -0,0 +1,5 @@
+---
+"@fleet-sdk/blockchain-providers": patch
+---
+
+Fix stream methods return types
diff --git a/packages/blockchain-providers/src/ergo-graphql/ergoGraphQLProvider.ts b/packages/blockchain-providers/src/ergo-graphql/ergoGraphQLProvider.ts
index 59d4c0f..5a92203 100644
--- a/packages/blockchain-providers/src/ergo-graphql/ergoGraphQLProvider.ts
+++ b/packages/blockchain-providers/src/ergo-graphql/ergoGraphQLProvider.ts
@@ -226,7 +226,7 @@ export class ErgoGraphQLProvider<I = bigint> implements IBlockchainProvider<I> {
 
   async *streamUnconfirmedTransactions(
     query: TransactionQuery<GraphQLUnconfirmedTransactionWhere> & SkipAndTake
-  ): AsyncIterable<ChainProviderUnconfirmedTransaction<I>[]> {
+  ): AsyncGenerator<ChainProviderUnconfirmedTransaction<I>[]> {
     const pageSize = query.take ?? PAGE_SIZE;
     const queries = buildGqlUnconfirmedTxQueries(query);
 
@@ -259,7 +259,7 @@ export class ErgoGraphQLProvider<I = bigint> implements IBlockchainProvider<I> {
 
   async *streamConfirmedTransactions(
     query: TransactionQuery<GraphQLConfirmedTransactionWhere> & SkipAndTake
-  ): AsyncIterable<ChainProviderConfirmedTransaction<I>[]> {
+  ): AsyncGenerator<ChainProviderConfirmedTransaction<I>[]> {
     const pageSize = query.take ?? PAGE_SIZE;
     const queries = buildGqlConfirmedTxQueries(query);
 
diff --git a/packages/blockchain-providers/src/types/blockchainProvider.ts b/packages/blockchain-providers/src/types/blockchainProvider.ts
index 02f6aba..3250a43 100644
--- a/packages/blockchain-providers/src/types/blockchainProvider.ts
+++ b/packages/blockchain-providers/src/types/blockchainProvider.ts
@@ -142,14 +142,14 @@ export interface IBlockchainProvider<I> {
   /**
    * Stream boxes.
    */
-  streamBoxes(query: BoxQuery<BoxWhere>): AsyncIterable<ChainProviderBox<I>[]>;
+  streamBoxes(query: BoxQuery<BoxWhere>): AsyncGenerator<ChainProviderBox<I>[]>;
 
   /**
    * Stream unconfirmed transactions
    */
   streamUnconfirmedTransactions(
     query: TransactionQuery<UnconfirmedTransactionWhere>
-  ): AsyncIterable<ChainProviderUnconfirmedTransaction<I>[]>;
+  ): AsyncGenerator<ChainProviderUnconfirmedTransaction<I>[]>;
 
   /**
    * Get unconfirmed transactions
@@ -163,7 +163,7 @@ export interface IBlockchainProvider<I> {
    */
   streamConfirmedTransactions(
     query: TransactionQuery<ConfirmedTransactionWhere>
-  ): AsyncIterable<ChainProviderConfirmedTransaction<I>[]>;
+  ): AsyncGenerator<ChainProviderConfirmedTransaction<I>[]>;
 
   /**
    * Get confirmed transactions