caolan / caolan/highland

.map using a pipeline

Open
#531 5 comments 0 reactions 0 assignees View on GitHub
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

Open the contributing 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.