handle method

Stream<R> handle(
  1. ServiceCall call,
  2. Stream<Q> requests
)

Implementation

Stream<R> handle(ServiceCall call, Stream<Q> requests) {
  if (streamingResponse) {
    if (streamingRequest) {
      return handler(call, requests);
    } else {
      return handler(call, _toSingleFuture(requests));
    }
  } else {
    final response = streamingRequest
        ? handler(call, requests)
        : handler(call, _toSingleFuture(requests));
    return response.asStream();
  }
}