fix return types of stream methods

fleet-sdk · Sep 6, 2024 · 90ad0b8 · 90ad0b8
1 parent 4d8f501
commit 90ad0b8
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 5 deletions.
diff --git a/.changeset/late-pumpkins-raise.md 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
@@ -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
@@ -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