Should clients always block like in the java example?

In the example : client.sayHello(request).block()

Is it possible to do it in a more reactive way ?

Hello @yjonckhe. Example is very minimalistic to help users start quickly - generally one has application logic executed on some scheduler, and application’s main thread blocked until application is done - e.g. until BrokerClient is disposed:

Flux.interval(Duration.ofSeconds(1))
       .onBackpressureDrop()
       .flatmap(value -> helloClient.sayHello(HelloRequest.newBuilder().setName("hello " + value).build()))
       .take(Duration.ofMinutes(1))
       .doFinally(s -> brokerClient.dispose())
      .subscribe(response -> logger.info("Hello response: {}", response), err -> logger.error("Hello error", err));

brokerClient.onClose().block();