如何在ResponseEntity中包装Flux<MyObject>

import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import reactor.core.publisher.Flux;

Flux<MyObject> myObjectFlux = Flux.just(new MyObject("object1"), new MyObject("object2"));

ResponseEntity<Flux<MyObject>> responseEntity = ResponseEntity.ok(myObjectFlux);

responseEntity.headers(headers -> headers.set("Custom-Header", "Value"))
              .status(HttpStatus.CREATED);

import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import reactor.core.publisher.Flux;

public class MyObject {
    private String name;

    public MyObject(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }
}

public class Example {
    public static void main(String[] args) {
        Flux<MyObject> myObjectFlux = Flux.just(new MyObject("object1"), new MyObject("object2"));

        ResponseEntity<Flux<MyObject>> responseEntity = ResponseEntity.ok(myObjectFlux);

        responseEntity.headers(headers -> headers.set("Custom-Header", "Value"))
                      .status(HttpStatus.CREATED);

        // 其他操作...
    }
}