Как отправить поток событий (Flux), который остановится, когда в Spring WebFlux возникнет какое-либо условие

Question

Я хочу отправлять потоки событий объекта MongoDB Document до тех пор, пока какое-либо поле в документе не будет соответствовать моим условиям (например, String.equals())

Например,

MyDocument myDocument;
do {
    myDocument = myDocumentService.get(id);
    System.out.println(myDocument.toString());
} while(myDocument.getStatus().equalsIgnoreCase("Ready"));


@RequestMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<MyDocument> getStatus(@PathVariable int id) {
    Mono<MyDocument> myDocument = myDocumentService.get(id);
    return Flux.___what_should_I_use_here_?___(data)
}