RSocket AsyncAPI

@Controller
public class CourtCaseRSocketController {

  @MessageMapping("court-case.detail.stream")
  public Flux<CourtCaseDetailEvent> stream(CourtCaseDetailRequest request) {
    return service.stream(request);
  }
}

var asyncConfig = RsoketAsyncApiJsonFileWatcher.Config.builder()
    .watchDirectory("src/main/java")
    .asyncApiOutputFile("src/main/resources/static/asyncapi-rsocket.json")
    .build();