ClientCall<Q, R> constructor

ClientCall<Q, R>(
  1. ClientMethod<Q, R> _method,
  2. Stream<Q> _requests,
  3. CallOptions options, [
  4. TimelineTask? _requestTimeline,
])

Implementation

ClientCall(
  this._method,
  this._requests,
  this.options, [
  this._requestTimeline,
]) {
  _requestTimeline?.start(
    'gRPC Request: ${_method.path}',
    arguments: {
      'method': _method.path,
      'timeout': options.timeout?.toString(),
    },
  );
  _responses.onListen = _onResponseListen;
  if (options.timeout != null) {
    _timeoutTimer = Timer(options.timeout!, _onTimedOut);
  }
}