constructor ({ onError, onCompleted } = {}) {
    super()
    this._onError = onError
    this._onCompleted = onCompleted
  }
@param {Object} param -
@param {function(err: Error)} param.onError
@param {function(metadata)} param.onCompleted