Fix Stream.take(n) not returning immediately after the last item

broxus · Jul 10, 2024 · d6a2210 · d6a2210
1 parent 76b72c8
commit d6a2210
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "everscale-inpage-provider",
-  "version": "0.3.65",
+  "version": "0.3.66",
   "description": "Web3-like interface to the Everscale blockchain",
   "repository": "https://github.com/broxus/everscale-inpage-provider",
   "main": "dist/index.js",

diff --git a/src/stream.ts b/src/stream.ts
@@ -726,7 +726,8 @@ class StreamImpl<P, T, F extends boolean> implements Stream<P, T, F> {
         this.extractor(event, (item) => {
           if (state.index < n) {
             ++state.index;
-            return handler(item);
+            // NOTE: Execute the handler and ensure that `false` is returned right after the Nth call
+            return handler(item) && state.index < n;
           } else {
             return false;
           }