How to use the map function from highland

coreTransforms.js

GitHub: markbirbeck/sifttt

7
8
9
10
11
12
13
14
15
16
  constructor(fn) {
    this._fn = fn;
  }

  apply() {
    return h.map(this._fn);
  }
};

class DoTo extends Map {

3

2

2

+ 13 other calls in file

index.js

GitHub: ak--47/mixpanel-import

180
181
182
183
184
185
186
187
188
// @ts-ignore
_.consume(chunkForSize(config)),

// * send to mixpanel
// @ts-ignore
_.map((batch) => {
        config.requests++;
        return flush(batch, config);
}),

0

13

6

+ 7 other calls in file

index.js

GitHub: zoellner/gmail-batch-stream

175
176
177
178
179
180
181
182
183
184

const processingPipeline = function(filterErrors) {
  return _h.pipeline(
    _h.invoke('toString', ['utf8']),
    _h.through(parseMultiPart()),
    _h.map(parseHttpResponse),
    _h.map(function(doc) {
      if (filterErrors && !(doc && doc.statusCode && parseInt(doc.statusCode, 10) === 200)) {
        return null;
      }

2

8

0

+ 3 other calls in file

dynamo-streams.js

GitHub: ildella/ildella-test-commons

11
12
13
14
15
16
17
18
19
20
21
// })


const batchWrite = ({
  TableName, batch, parallel = 1,
}) => __.pipeline(
  __.map(wrapPutRequest),
  __.batch(batch),
  __.map(defaultDocumentClient.wrapBatchWriteRequest(TableName)),
  __.map(batch => defaultDocumentClient.batchWrite(batch)),
  __.map(__),

0

1

0

+ 11 other calls in file

hl2.js

GitHub: jvee/BuildStream

44
45
46
47
48
49
50
51
52
53
stream.regExp = RE_INCLUDE;
stream.cwd = options.cwd || process.cwd();

function create() {
    return _.pipeline(
        _.map(split),
        _.append(cache),
        _.flatten
    );
}

0

0

0

+ 3 other calls in file