$createStreamingCall<Q, R> method
ResponseStream<R>
$createStreamingCall<Q, R>(
- ClientMethod<
Q, R> method, - Stream<
Q> requests, { - CallOptions? options,
Implementation
ResponseStream<R> $createStreamingCall<Q, R>(
ClientMethod<Q, R> method, Stream<Q> requests,
{CallOptions? options}) {
var invoker = (method, requests, options) =>
ResponseStream<R>(_channel.createCall<Q, R>(method, requests, options));
for (final interceptor in _interceptors.reversed) {
final delegate = invoker;
invoker = (method, requests, options) => interceptor
.interceptStreaming<Q, R>(method, requests, options, delegate);
}
return invoker(method, requests, _options.mergedWith(options));
}