server<I extends Object, O extends Object> method
Stream<O>
server<I extends Object, O extends Object>(
- Spec<
I, O> spec, - I input, {
- void onHeader()?,
- void onTrailer()?,
- AbortSignal? signal,
- Headers? headers,
Convenient api over stream for server streaming calls.
Implementation
Stream<O> server<I extends Object, O extends Object>(
Spec<I, O> spec,
I input, {
void Function(Headers)? onHeader,
void Function(Headers)? onTrailer,
AbortSignal? signal,
Headers? headers,
}) async* {
final res = await t.stream(
spec,
Stream.value(input),
CallOptions(headers: headers, signal: signal),
);
onHeader?.call(res.headers);
yield* res.message;
onTrailer?.call(res.trailers);
}