interceptStreaming<Q, R> method

  1. @override
ResponseStream<R> interceptStreaming<Q, R>(
  1. ClientMethod<Q, R> method,
  2. Stream<Q> requests,
  3. CallOptions options,
  4. ClientStreamingInvoker<Q, R> invoker,
)

Implementation

@override
ResponseStream<R> interceptStreaming<Q, R>(
  ClientMethod<Q, R> method,
  Stream<Q> requests,
  CallOptions options,
  ClientStreamingInvoker<Q, R> invoker,
) {
  final modifiedOptions = options.mergedWith(
    CallOptions(
      providers: [
        _injectToken, // method signatures match, so we should be ok
      ],
    ),
  );
  return invoker(method, requests, modifiedOptions);
}