serverStream method

Future<DynamicStream> serverStream(
  1. String service,
  2. String method,
  3. GenericMessage req, {
  4. Map<String, String>? metadata,
  5. Duration? timeout,
})

Implementation

Future<DynamicStream> serverStream(String service, String method,
    GenericMessage req,
    {Map<String, String>? metadata, Duration? timeout}) async {
  final m = _method(service, method);
  final stream = await _channel.serverStream(
      m.path, _BoundMessage(m.input!, req, _model),
      metadata: metadata, timeout: timeout);
  return DynamicStream(stream, m.output!, _model);
}