createCall<Q, R> method
ClientCall<Q, R>
createCall<Q, R>(
- ClientMethod<
Q, R> method, - Stream<
Q> requests, - CallOptions options
Initiates a new RPC on this connection.
Implementation
@override
ClientCall<Q, R> createCall<Q, R>(
ClientMethod<Q, R> method, Stream<Q> requests, CallOptions options) {
_callEvents.add(method.path);
final call = ClientCall(method, requests, options);
getConnection().then((connection) {
if (call.isCancelled) return;
connection.dispatchCall(call);
}, onError: call.onConnectionError);
return call;
}