How to use the consume function from highland

promise_delay.js

GitHub: Streampunk/casparcl

21
22
23
24
25
26
27
28
29
30
      p(x).then((m) => {
        push(null, m)
      })
    }
  }
  return H.consume(ep)
}

H((push, next) => {
  console.log('*** GENERATOR ***', genc++)

0

38

25

index.js

GitHub: ak--47/mixpanel-import

176
177
178
179
180
181
182
183
184
185
// @ts-ignore
_.batch(config.recordsPerBatch),

// * batch for req size
// @ts-ignore
_.consume(chunkForSize(config)),

// * send to mixpanel
// @ts-ignore
_.map((batch) => {

0

13

6

+ 3 other calls in file

permutations.js

GitHub: histograph/graphmalizer-core

23
24
25
26
27
28
29
30
31
32
}

module.exports = function() {
    return H.pipeline(
        H.collect(),
        H.consume(function (err, x, push, next){
            if (err) {
                // pass errors along the stream and consume next value
                push(err);
                next();

1

0

7

hl2.js

GitHub: jvee/BuildStream

9
10
11
12
13
14
15
16
17
18
19
20


function Wrapper(begin, end) {
    var isStarted = false;


    return _.pipeline(
        _.consume(function (err, chunk, push, next) {
            if (err) {
                push(err);
                next();
                return;

0

0

0

+ 3 other calls in file