.map using a pipeline
- Dominant language
- JavaScript
- Stars
- 3.4k
- Forks
- 145
- PR merge metrics
- No merged PRs in 30d
Description
How would you preform a .map using a pipeline as the target?
This is what I came up with so far:
```
const $ = require('highland');
function (input, processArray, concurrency) {
return $(input)
.map(record => $([record]).through(pipeline(processArray)))
.mergeWithLimit(concurrency);
}
```
Contributor guide
Research direction
Start by reviewing the issue's proposed function and the map, through, and mergeWithLimit entry points it uses. Determine whether the requested pipeline target is an existing capability or requires a new API, then verify the intended behavior with a focused stream example. Done means the pipeline can be used as the map target with the requested concurrency semantics.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- javascript, node.js
- Domain
- backend
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100