grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactor: drop usage of _.flatMap

This commit is contained in:
Justin Beckwith 2018-11-15 13:30:19 -08:00
parent c9d4fbec0a
commit cc1d1f4913
2 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/grpc-native-core/src/client_interceptors.js
View File

@ -716,7 +716,7 @@ function _getStreamReadCallback(emitter, call, get_listener, deserialize) {
* @return {boolean} * @return {boolean}
*/ */
function _areBatchRequirementsMet(batch_ops, completed_ops) { function _areBatchRequirementsMet(batch_ops, completed_ops) {
var dependencies = _.flatMap(batch_ops, function(op) { var dependencies = common.flatMap(batch_ops, function(op) {
return OP_DEPENDENCIES[op] || []; return OP_DEPENDENCIES[op] || [];
}); });
for (var i = 0; i < dependencies.length; i++) { for (var i = 0; i < dependencies.length; i++) {
@ -752,7 +752,7 @@ function _startBatchIfReady(call, batch, batch_state, callback) {
// dependencies are met as a result. // dependencies are met as a result.
call.startBatch(batch, callback); call.startBatch(batch, callback);
completed_ops = _.union(completed_ops, batch_ops); completed_ops = _.union(completed_ops, batch_ops);
deferred_batches = _.flatMap(deferred_batches, function(deferred_batch) { deferred_batches = common.flatMap(deferred_batches, function(deferred_batch) {
var deferred_batch_ops = Object.keys(deferred_batch).map(Number); var deferred_batch_ops = Object.keys(deferred_batch).map(Number);
if (_areBatchRequirementsMet(deferred_batch_ops, completed_ops)) { if (_areBatchRequirementsMet(deferred_batch_ops, completed_ops)) {
call.startBatch(deferred_batch.batch, deferred_batch.callback); call.startBatch(deferred_batch.batch, deferred_batch.callback);

15
packages/grpc-native-core/src/common.js
View File

@ -112,6 +112,21 @@ exports.getMethodType = function(method_definition) {
} }
}; };
/**
* Iterate over a collection of items, and run the given handler.
* Return the results as a flattened array of values.
*
* @private
*
* @param {Array} collection Array of items to process
* @param {Function} handler The function to call on each element in the array
* @return {Array} A flattened array of results.
*/
exports.flatMap = function(collection, handler) {
const mapped = collection.map(handler);
return mapped.reduce((acc, curr) => acc.concat(curr), []);
}
/** /**
* Given an array of property names and an array of values, * Given an array of property names and an array of values,
* combine the two into an object map. * combine the two into an object map.