How to use the mergeWithLimit function from highland

index.js

GitHub: ak--47/mixpanel-import

187
188
189
190
191
192
193
194
195
196
        return flush(batch, config);
}),

// * concurrency
// @ts-ignore
_.mergeWithLimit(config.workers),

// * verbose
// @ts-ignore
_.doto(() => {

0

13

0

+ 3 other calls in file

index.js

GitHub: zoellner/gmail-batch-stream

207
208
209
210
211
212
213
214
215
    _h.flatMap(_h.wrapCallback(function(doc, callback) {
      _this.rl.getTokens(_this.quotaSize * _this.batchSize, () => callback(null, doc));
    })),
    _h.map(mapToMultipartRequest),
    _h.map(batch => _h(request(batch).pipe(processingPipeline(_this.filterErrors)))),
    _h.mergeWithLimit(_this.parallelRequests)
  );

};

2

8

3

+ 3 other calls in file