사용자 도구

사이트 도구


reactive_programming:reactor

문서의 이전 판입니다!


Project Reactor

동기 호출을 비동기로 전환하기(JDBC 등)

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());
}

참조

reactive_programming/reactor.1547518987.txt.gz · 마지막으로 수정됨: 2019/01/15 11:23 저자 kwon37xi