문서의 이전 판입니다!
CompletableFuture
, @Async
, 그리고 Reactor가 제공해주는 기능등을 통해 동기 호출을 쓰레드 기반 비동기로 전환할 수 있다.Mono blockingWrapper = Mono.fromCallable(() -> { return /* make a remote synchronous call */ }); blockingWrapper = blockingWrapper.subscribeOn(Schedulers.elastic());
@GetMapping(value = "/v1/measurements") public Flux<Measurement> getMeasurements() { return Flux.defer(() -> Flux.fromIterable(repository.findByFromDateGreaterThanEqual(new Date(1486980000L)))) .subscribeOn(Schedulers.elastic()); }