@Override
    public Flux<HelloReply> lotsOfReplies(Mono<HelloRequest> request) {
        return request
                .flatMapMany(
                        it -> Flux.interval(Duration.ofSeconds(1))
                                  .take(5)
                                  .map(index -> "Hello, " + it.getName() + "! (sequence: " + (index + 1) + ')')
                )
                // You can make your Flux/Mono publish the signals in the RequestContext-aware executor.
                .publishOn(Schedulers.fromExecutor(ServiceRequestContext.current().eventLoop()))
                .map(HelloServiceImpl::buildReply);
    }
Sends 5 {@link HelloReply} responses when receiving a request.
examples/grpc-reactor/src/main/java/example/armeria/grpc/reactor/HelloServiceImpl.java