src/engine/inputPipes.js
function inputPipes (pipe, taskKey) {
  var pipes = []

  function pushPipe (key) {
    pipes.push(pipe[key])
  }

  function ifIsInputPipe (key) {
    return pipe[key][1] === taskKey
  }

  Object.keys(pipe).filter(ifIsInputPipe).forEach(pushPipe)

  return pipes
}
function inputPipes (pipe, taskKey) {
  var pipes = []

  function pushPipe (key) {
    pipes.push(pipe[key])
  }

  function ifIsInputPipe (key) {
    return pipe[key][1] === taskKey
  }

  Object.keys(pipe).filter(ifIsInputPipe).forEach(pushPipe)

  return pipes
}
function inputPipes ( pipe , taskKey ) { var pipes = [ ] function pushPipe ( key ) { pipes . push ( pipe [ key ] ) } function ifIsInputPipe ( key ) { return pipe [ key ] [ 1 ] === taskKey } Object . keys ( pipe ) . filter ( ifIsInputPipe ) . forEach ( pushPipe ) return pipes }
Compute pipes that feed a task.

@param {Object} pipe
@param {String} taskKey

@returns {Array} pipes
Compute pipes that feed a task .