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) {
  var newOptions = options.mergedWith(
    CallOptions(metadata: <String, String>{'authorization': jwt}),
  );
  return invoker(
    method,
    requests,
    newOptions,
  );
}