Spring Boot 2.2 RSocket consumer

GreetingConsumerController.java

@RestController
@RequiredArgsConstructor
@FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true)
public class GreetingConsumerController {
    Mono<RSocketRequester> requester;

    @GetMapping("/greet/{name}")
    public Publisher<GreetingResponse> greet(@PathVariable String name) {
        return requester.flatMap(req -> req.route("greet")
                  .data(GreetingRequest.builder().name(name).build())
                  .retrieveMono(GreetingResponse.class)
        );
    }
}