如何从Http集成流程创建Spring Reactor Flux？

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

@RestController
@RequestMapping("/api")
public class ApiController {
    // 处理GET请求
    @GetMapping("/data")
    public Flux<Data> getData() {
        // 在这里编写获取数据的逻辑
        // 返回一个Flux对象
    }

    // 处理POST请求
    @PostMapping("/data")
    public Mono<ResponseEntity<String>> createData(@RequestBody Data data) {
        // 在这里编写创建数据的逻辑
        // 返回一个Mono对象
    }
}

@GetMapping("/data")
public Flux<Data> getData() {
    List<Data> dataList = // 获取数据的逻辑
    return Flux.fromIterable(dataList);
}

@PostMapping("/data")
public Mono<ResponseEntity<String>> createData(@RequestBody Data data) {
    // 创建数据的逻辑
    return Mono.just(ResponseEntity.ok("Data created successfully"));
}