Compare commits
5 Commits
1d508656c1
..
v0.0.9
| Author | SHA1 | Date | |
|---|---|---|---|
| 45cffb541b | |||
| 5ea4aed9fb | |||
| a56db71c1a | |||
| bba77ae6b4 | |||
| 26fb36ca19 |
@@ -1,4 +1,4 @@
|
|||||||
# push-take-until
|
# @push-stream-std/push-take-until
|
||||||
|
|
||||||
Take values from a source stream until a signal stream emits or ends.
|
Take values from a source stream until a signal stream emits or ends.
|
||||||
|
|
||||||
@@ -28,8 +28,7 @@ npm config set -- //hub.kl1.tenere.ai/api/packages/push-stream-std/npm/:_authTok
|
|||||||
npm install @push-stream-std/push-take-until
|
npm install @push-stream-std/push-take-until
|
||||||
```
|
```
|
||||||
|
|
||||||
## Description
|
## Why
|
||||||
|
|
||||||
A push-stream through that passes through values from the source until the provided signal stream ends. When the signal stream ends (either normally or via abort), the take-until stream immediately ends the upstream source and downstream sink, closing the pipeline. This is useful for implementing cancellation patterns — for example, taking values from an event stream until a "stop" button is clicked.
|
A push-stream through that passes through values from the source until the provided signal stream ends. When the signal stream ends (either normally or via abort), the take-until stream immediately ends the upstream source and downstream sink, closing the pipeline. This is useful for implementing cancellation patterns — for example, taking values from an event stream until a "stop" button is clicked.
|
||||||
|
|
||||||
## API
|
## API
|
||||||
@@ -51,8 +50,5 @@ Tests cover passthrough before signal ends, stopping after signal end, normal en
|
|||||||
|
|
||||||
## Requirements
|
## Requirements
|
||||||
|
|
||||||
Node.js 18 or later. ESM only.
|
Node.js 22 or later. ESM only.
|
||||||
|
|
||||||
## License
|
|
||||||
|
|
||||||
MIT
|
|
||||||
|
|||||||
Generated
+16
@@ -0,0 +1,16 @@
|
|||||||
|
{
|
||||||
|
"name": "@push-stream-std/push-take-until",
|
||||||
|
"version": "0.0.8",
|
||||||
|
"lockfileVersion": 3,
|
||||||
|
"requires": true,
|
||||||
|
"packages": {
|
||||||
|
"": {
|
||||||
|
"name": "@push-stream-std/push-take-until",
|
||||||
|
"version": "0.0.8",
|
||||||
|
"license": "SEE LICENSE IN LICENSE",
|
||||||
|
"engines": {
|
||||||
|
"node": ">=22.0.0"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+7
-2
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@push-stream-std/push-take-until",
|
"name": "@push-stream-std/push-take-until",
|
||||||
"version": "0.0.3",
|
"version": "0.0.9",
|
||||||
"description": "Take elements until signal stream emits",
|
"description": "Take elements until signal stream emits",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"main": "index.js",
|
"main": "index.js",
|
||||||
@@ -32,5 +32,10 @@
|
|||||||
],
|
],
|
||||||
"publishConfig": {
|
"publishConfig": {
|
||||||
"registry": "https://hub.kl1.tenere.ai/api/packages/push-stream-std/npm/"
|
"registry": "https://hub.kl1.tenere.ai/api/packages/push-stream-std/npm/"
|
||||||
}
|
},
|
||||||
|
"repository": {
|
||||||
|
"type": "git",
|
||||||
|
"url": "https://hub.kl1.tenere.ai/push-stream-std/push-take-until.git"
|
||||||
|
},
|
||||||
|
"dependencies": {}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user