project-reactor

0열

1답변

후크와 리프트를 사용하여 ThreadLocal에 컨텍스트를 푸시

가입자가 onNext 신호를 받기 전에 반응적 컨텍스트를 ThreadLocal 변수로 푸시 할 수있는 방법이 있는지 스스로에게 묻고있었습니다. 원자로 코어 내부를 파고있는 동안 Hooks 클래스와 Lift BiFunction을 발견했습니다. 다음 구현으로 클래스를 만들었습니다. 이 클래스는 Context를 보유하고 필요한 BiFunction 인터페이스를 구

project-reactor 2017-11-26

---

0열

1답변

프로젝트 - 리액터를 사용하여 왼쪽 외부 조인 두 개의 정렬 된 스파 스 시퀀스

스파 스 ID가있는 엔티티의 두 정렬 된 스트림이 주어집니다. Flux<Long> stream1 = Flux.fromArray(new Long[] {1L, 3L, 4L, 5L, 6L}); Flux<Long> stream2 = Flux.fromIterable(List.of(1L, 2L, 3L, 4L, 6L, 7L)); SQL의 내용을 FULL OUTER

java project-reactor reactive-streams 2017-11-27

---

0열

1답변

데이터베이스에 모노를 구독 할 때 일회용품을 보관하십시오.

현재 reactor-core을 탐색 중입니다. Mono를 구독하고 구독자의 실행을 처리 할 수있는 일회용품을 저장할 수 있습니다. Mono<Object> task1 = Mono.just("Task1"); Mono<Object> task2 = Mono.just("Task2"); System.out.println(System.currentTimeMillis

spring rx-java rx-java2 project-reactor 2017-12-07

---

2열

1답변

"브리징"gRPC StreamObserver의 반응기 플럭스

gRPC StreamObserver에서 Reactor Flux을 생성하고 싶습니다. StreamObserver가 각 인터페이스를 기본적으로 구현하지 않는 한이 작업을 수행해야합니다 (예 : this issue 참조). 내가 생각 해낸 무엇 대략 같다 다음 : 여기 원자로를 사용하려는 이유는 주요 아이디어는 그렇게 병렬로 여러 스레드 위에 "무거운 작업"을

java grpc project-reactor grpc-java 2017-10-23

---

1열

1답변

Socket.IO-client Java 용 Reactor Flux 프록시

Socket.IO-client Java에서 데이터를 가져와야하는 Spring WebFlux 엔드 포인트를 구현 중입니다. 들어오는 데이터를 Flux 스트림으로 수집하는 방법을 이해하지 못합니다. 어떻게 새 Flux를 생성하고 들어오는 데이터에 구독 할 수 있습니까? 충고에 감사하다. @GetMapping("/streaming", produces = Medi

project-reactor spring-webflux socket.io-java-client 2017-11-04

---

1열

1답변

차단 작업에 Mono <Object> .publishOn (Schedulers.elastic)을 사용할 수 있습니까? 반응 스트림에서 작업을 차단 사용할 때

나는 우리가 내 게시자가 항목의 목록을 발행 할 때 말이 이해 Publisher<Object>.publishOn(Schedulers.elastic).subscribe(//blocking operations go here) 사용해야 이해 (예를 들어 : 플럭스) 미래 항목은 현재까지 기다릴 필요가 없습니다 차단 작업으로 인해 항목이 차단되었습니다. 그러나 M

spring spring-boot reactive-programming project-reactor spring-webflux 2017-11-07

---

0열

1답변

제공된 모든 메시지를 원자로 플럭스 처리하는 방법

Flux 파이프 라인을 사용하여 여러 스레드에서 제공되는 모든 메시지를 처리하려고한다고 가정합니다. 아래의 코드를 살펴 보겠습니다. @Test public void testFluxCreate() throws InterruptedException { EmitterProcessor<String> processor = EmitterProcessor.c

reactive-programming project-reactor 2017-11-09

---

1열

1답변

Reactor를 작업 실행자로 사용하는 올바른 방법

저는 documentation에서 Reactor를 작업 실행자로 사용하는 방법을보고 있습니다. 나는 다음 ThreadService 등이 종료 대기, 일부 작업 제출을 병렬화 할, 울부 짖는 소리 샘플 : 만 목록 final List<Integer> result = Flux.range(1, 15) .parallel() .runOn(Sched

java project-reactor 2017-11-17

---

1열

1답변

Webflux mongo 여러 모델 저장

내 응용 프로그램에는 서버와 사용자가 있으며 각 사용자는 여러 개의 서버를 가질 수 있습니다. User의 서버 목록입니다 @DBref : 그 후 나는 사용자의 서버 목록에 서버를 추가하고 사용자를 저장, 내가 먼저 작성하고 서버를 저장하는 서버를 만들려는 컨트롤러에서 @DBRef private List<Server> servers; : @PostMap

spring mongodb reactive project-reactor spring-webflux 2017-11-22

---

0열

2답변

Reactor - 나머지 POST 메서드에서받은 메시지를 버퍼하는 방법

Reactor를 처음 사용하고 있으며 이전에 마지막으로 저장 한 이후로 30 초를 초과 할 때까지 100 개의 메시지를 수신하기 위해 대기하는 기존 스프링리스 서비스를 업데이트하려고합니다. 내받은 메시지를 저장하십시오. @RequestMapping(method = RequestMethod.POST) @ResponseStatus(value = HttpSta

spring rest spring-boot project-reactor 2017-11-23

---