call method

Future<Stream<T>> call(
  1. RpcClient client,
  2. I data, {
  3. Future<void>? cancelled,
})

Invokes this function through client.

Completing cancelled stops request and response streaming with RpcCancelledException.

Implementation

Future<Stream<T>> call(RpcClient client, I data, {Future<void>? cancelled}) =>
    client.stream(this, data, cancelled: cancelled);