How properly test webflux method with long operation
For example Spring Webflux / Reactor release calling thread
@GetMapping("/foo")
public Mono<Void> bar() {
return Mono.fromCallable(() -> someService.veryLongSyncOperation())
.subscribeOn(Schedulers.elastic())
.then();
}
I return Mono but veryLongSyncOperation works.
So how properly write test with StepVerifier for such method without Thread.sleep(XXX); Get results of veryLongSyncOperation and check them.