revert: keep break in limit step

zazuko · Sep 13, 2024 · 24b590d · 24b590d
1 parent c952d1f
commit 24b590d
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 9 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/base/limit.js b/packages/base/limit.js
@@ -12,6 +12,8 @@ export default function limit(limit) {
       count++
       if (count <= limit) {
         yield chunk
+      } else {
+        break
       }
     }
   }

diff --git a/test/e2e/definitions/limit-offset.ttl b/test/e2e/definitions/limit-offset.ttl
@@ -11,5 +11,9 @@
           [ base:streamValues ( "{ age: 34 }"^^code:EcmaScript "{ age: 23 }"^^code:EcmaScript "{ age: 10 }"^^code:EcmaScript) ]
           [ base:offset (1) ]
           [ base:limit (1) ]
+          # pipeline stalls if limit is last step
+          [
+            base:map( "value => value"^^code:EcmaScript )
+          ]
         )
     ] .