How to use the batch function from highland

index.js

GitHub: ak--47/mixpanel-import

172
173
174
175
176
177
178
179
180
181
        return data;
}),

// * batch for # of items
// @ts-ignore
_.batch(config.recordsPerBatch),

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

0

13

0

+ 3 other calls in file

index.js

GitHub: zoellner/gmail-batch-stream

201
202
203
204
205
206
207
208
209
210
    _h.compact()
  );
};

return _h.pipeline(
  _h.batch(_this.batchSize),
  _h.flatMap(_h.wrapCallback(function(doc, callback) {
    _this.rl.getTokens(_this.quotaSize * _this.batchSize, () => callback(null, doc));
  })),
  _h.map(mapToMultipartRequest),

2

8

3

+ 3 other calls in file

dynamo-streams.js

GitHub: ildella/ildella-test-commons

12
13
14
15
16
17
18
19
20
21
22


const batchWrite = ({
  TableName, batch, parallel = 1,
}) => __.pipeline(
  __.map(wrapPutRequest),
  __.batch(batch),
  __.map(defaultDocumentClient.wrapBatchWriteRequest(TableName)),
  __.map(batch => defaultDocumentClient.batchWrite(batch)),
  __.map(__),
  __.parallel(parallel) // TODO fix lint rules, we want a comma here.

0

1

0

+ 2 other calls in file