serverStream method

Future<ClientStream> serverStream(
  1. String path,
  2. Marshaler req, {
  3. Map<String, String>? metadata,
  4. Duration? timeout,
})

Start a server-streaming call.

Implementation

Future<ClientStream> serverStream(String path, Marshaler req,
    {Map<String, String>? metadata, Duration? timeout}) async {
  final stream = await _open(path, metadata, timeout: timeout);
  _sendMessage(stream, req);
  _halfClose(stream);
  return stream;
}