code: function stream (input, value) {
    value.on('data', data => input.push(data))
    value.on('error', err => error(input, err))
    value.on('end', () => input.push(null))
  }
docs: End input stream with given stream.
  
  @param {Stream} input
  @param {Stream} value
  @api private