diff --git a/package-lock.json b/package-lock.json
index 68528930..41789561 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -27679,7 +27679,7 @@
     },
     "packages/cli": {
       "name": "barnard59",
-      "version": "5.0.4",
+      "version": "5.0.5",
       "license": "MIT",
       "dependencies": {
         "@opentelemetry/api": "^1.0.0",
@@ -27691,7 +27691,7 @@
         "@opentelemetry/semantic-conventions": "^0.24.0",
         "@opentelemetry/tracing": "^0.24.0",
         "@rdfjs/namespace": "^2.0.0",
-        "barnard59-core": "6.0.1",
+        "barnard59-core": "6.1.0",
         "barnard59-env": "1.2.6",
         "commander": "^11.0.0",
         "find-up": "^7.0.0",
@@ -27718,7 +27718,7 @@
         "barnard59-base": "^2.4.2",
         "barnard59-formats": "^4.0.0",
         "barnard59-graph-store": "^6.0.1",
-        "barnard59-http": "^2.0.0",
+        "barnard59-http": "^2.1.0",
         "barnard59-shell": "^0.1.0",
         "barnard59-test-support": "^0.0.3",
         "chai": "^4.3.7",
@@ -27847,7 +27847,7 @@
     },
     "packages/core": {
       "name": "barnard59-core",
-      "version": "6.0.1",
+      "version": "6.1.0",
       "license": "MIT",
       "dependencies": {
         "@opentelemetry/api": "^1.0.1",
@@ -27867,7 +27867,7 @@
         "@rdfjs/namespace": "^2.0.0",
         "@types/readable-stream": "^4.0.9",
         "barnard59-env": "^1.2.2",
-        "barnard59-http": "^2.0.0",
+        "barnard59-http": "^2.1.0",
         "barnard59-test-support": "^0.0.3",
         "chai": "^4.3.7",
         "get-stream": "^6.0.1",
@@ -27940,12 +27940,12 @@
     },
     "packages/cube": {
       "name": "barnard59-cube",
-      "version": "1.4.8",
+      "version": "1.4.9",
       "license": "MIT",
       "dependencies": {
         "barnard59-base": "^2.4.2",
         "barnard59-formats": "^4.0.0",
-        "barnard59-http": "^2.0.0",
+        "barnard59-http": "^2.1.0",
         "barnard59-rdf": "^3.4.0",
         "barnard59-shacl": "^1.4.9",
         "barnard59-sparql": "^2.3.0",
@@ -28254,7 +28254,7 @@
     },
     "packages/http": {
       "name": "barnard59-http",
-      "version": "2.0.0",
+      "version": "2.1.0",
       "license": "MIT",
       "dependencies": {
         "@opentelemetry/api": "^1.0.1",
@@ -28466,7 +28466,7 @@
     },
     "packages/shacl": {
       "name": "barnard59-shacl",
-      "version": "1.4.9",
+      "version": "1.4.10",
       "license": "MIT",
       "dependencies": {
         "@rdfjs/fetch": "^3.0.0",
diff --git a/packages/base/limit.js b/packages/base/limit.js
index a14bee87..bb5ff98c 100644
--- 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
index fb35a296..83087cab 100644
--- 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 )
+          ]
         )
     ] .