project-reactor

1열

1답변

BubblingException을 처리하는 방법

웹 요청을하는 Mono 2 명을 보유하고 있으며 Mono.zip을 사용하여 결과를 병합합니다. 요청 중 하나가 오류가 발생하면 나는 onErrorMap을 사용하여 오류를 처리하여 사용자 정의 WebExceptionHandler에 의해 처리되는 예외를 변환합니다. 하지만 원자로에 의해 처리되지 않습니다 예외 얻을 수행하여 : private fun <T> cr

project-reactor spring-webflux 2017-12-08

---

1열

1답변

Spring 5에서 mongodb에 사용자를 저장할 수 없습니다. WebFlux

Spring WebFlux와 반응 형으로 사용자를 Mongo 데이터베이스에 저장하려고하는데 데이터가 저장되지 않으므로 Java 8, Spring 5 및 mongodb가 있습니다.이 내 엔티티 :이 @Document public class User { @Id private String id; private String userna

java mongodb project-reactor spring-webflux 2017-12-08

---

0열

1답변

큰 스트림 분할시 스프링 통합 백 프레셔 오류가 발생했습니다.

목표는 로컬로 다운로드하지 않고 웹 서버에서 큰 json.gz 파일 (4GB 압축, 약 12GB 비 압축, 1200 만 행)을 데이터베이스로 스트리밍하는 것입니다. body = response.body().byteStream(); // thanks okhttp reader = new InputStreamReader(body, StandardCharsets

spring spring-integration reactive-programming project-reactor enterprise-integration 2017-12-09

---

0열

1답변

Reactor 3의 컨텍스트를 업데이트하는 방법이 있습니까? 반응 순서에 추가 <a href="http://projectreactor.io/docs/core/snapshot/reference/#context" rel="nofollow noreferrer">reference guide</a> 문맥에 따라

불변이다 사용 새로운 문맥 인스턴스를 리턴 키 - 값 쌍을 저장 (객체 키 오브젝트 값)을 넣어. 그런 다음 시퀀스의 컨텍스트를 업데이트하기 위해 일종의 "해결 방법"이 있는지 궁금합니다. 예를 들어 이전 코드를 바꾸는 것과 같습니다.이 @Test public void contextGlobalTest() { Flux<String> chars =

java project-reactor 2017-12-13

---

0열

1답변

Project Reactor : 오류 처리에 대한 오해의 소지가있는 문서

오류 처리와 관련하여 Reactor 참조 문서를 읽었습니다. 예를 들어이 부분에 대한 fallback method : Flux.just("key1", "key2") .flatMap(k -> callExternalService(k)) .onErrorResume(e -> getFromCache(k)); 그러나 onErrorResume()

spring project-reactor 2017-12-15

---

0열

2답변

Reactor Scheduler는 주 스레드가 완료된 후에도 계속 실행됩니다. 반응기 (3) 사용하는 동안

나는 스케줄러 작업자 스레드를 정리하는 방법에 대한 질문이 내가 위의 코드가 실행되면 내가 볼 무엇 Flux.range(1, 10000) .publishOn(Schedulers.newElastic("Y")) .doOnComplete(() -> { // WHAT should one do to ensure the worker threads are

java project-reactor 2017-12-20

---

0열

1답변

왜 Spring ReactiveMongoRepository가 Mono에 대한 저장 방법을 가지고 있지 않습니까?

ReactiveMongoRepository를 확장 한 MovieRepository가 있습니다. 반응적인 방법으로 단일 POJO를 저장하려고합니다. 그러나 ReactiveMongoRepository는 Mono 또는 Publisher에 대한 저장 방법을 제공하지 않습니다. 나는 block() 메서드를 사용하거나 ReactiveMongoRepository에서 s

spring reactive-programming project-reactor 2017-12-21

---

1열

1답변

원자로 매핑 모노 <Boolean>는 <Void>

내가 Mono<Boolean>을 돌려 기능을 가지고 있고 (이것은 내 컨트롤러 메서드에서 반환 뭔가 때문에) Mono<Void>에 매핑 할 모노. .flatMap { Mono.empty<Void>() } 대신 Mono을 돌려주는 더 좋은 방법이 있습니까? 매핑 기능이 null을 (를) 허용하지 않기 때문에 .map{ null }을 사용할 수 없습니다.

spring project-reactor 2017-12-23

---

1열

1답변

유한 소스의 반응성 스트림이 향후 이벤트를 위해 열려 있습니다.

비 차단 I/O (Spring Boot 2.0.0.M7) 용으로 Spring Webflux, Spring Data 및 Project Reactor를 사용하고 있습니다. 내 목표는 클라이언트가 일부 기준에 따라 엔드 포인트에서 모든 자원을 요청할 수 있도록 주식 시세와 같은 API를 작성하고 초기 요청 후에 작성된 새 자원을 수신하는 것입니다. Reactiv

spring-data reactive-programming project-reactor spring-webflux 2017-12-27

---

0열

1답변

Reactor - flatMap의 출력에서 ​​블록을 호출하면 ClassCastException이 발생합니다.

스프링 부트 2.0.0.M7 및 프로젝트 리액터를 사용하고 있습니다. 내 문제는 단위 테스트를 작성하는 동안 발생한 이상한 동작과 관련이 있습니다. 또한 flatMap의 출력을 저장소에 공급하면서이 문제에 봉착했습니다. Mono<Foo> create(Mono<FooResource> resourceMono) { resourceMono.flatMap(

spring-data project-reactor 2017-12-27

---