<dependency>
  <groupId>com.dtflys.forest</groupId>
  <artifactId>forest-reactor</artifactId>
  <version>1.8.0</version>
</dependency>

public interface ReactorClient {

   // 支持 Flux 作为返回类型
    @Get("/flux")
    Flux<String> testFlux();

    // 支持 Mono 作为返回类型
    @Get("/mono")
    Mono<String> testMono();

}

Forest.get("/sse")
    .sse(ReactorSSE.class) // 使用 ReactorSSE 类
    .setOnMessage((event, sink) -> {
        String data = event.value(String.class);
        sink.next("data: " + data); // 发布消息
    })
    .toFlux(String.class) // 转化为 Flux<String> 类型
    .subscribe(name -> {
        // 订阅消息
        System.out.println("value -> " + name);
    });