reactive-streams

0열

1답변

나는 리 액티브 스트림이 메시지 구동인지 또는 이벤트 구동인지 알아 내려고하고있다. Reactive Streams는 Message Driven이라고 선언문마다 다른 버전이 있습니다. 그러나 그들은 다른 기사에서 이벤트에 대해서만 말합니다. 아니면 둘 다 이벤트를 포함 할 수있는 메시지입니까?

6열

1답변

Akka 스트림 형

에 의해 스트림을 분할 나는 다음과 같은 간단한 경우 클래스 계층이 있습니다 sealed trait Message case class Foo(bar: Int) extends Message case class Baz(qux: String) extends Message 을 그리고 나는 Flow[Message, Message, NotUsed] (코덱과 웹

2열

1답변

cyclops-react와 async-retry : 타임 아웃시 재 시도하는 방법?

나는 cyclops-react를 async-retry와 함께 사용하기 시작했습니다. 나는 아직도 그걸로 길을 잃었습니다. 나는 SimpleReact를 사용하여 서버에서 타임 아웃을 시뮬레이션하지만 난 결코 이런 일에 시간 제한받지 해요 : 거기에 어떤 누락 private List<Object> executeParallel() { List<Objec

6열

1답변

null이없는 두 스트림을 병합하고 쌍에 조건을 적용하는 방법은 무엇입니까?

고려해야 할 것은 두 개의 데이터 스트림이 병합되고이 두 스트림 간의 데이터 조건을 적용하는 방법이 있습니까? 예를 들어 Stream A : A, B, C, D.... Stream B : -, A, -, -.... Composed : (A,-),(B,A),(C,-),(D,-).... rxjs를 사용하여 위의 작성된 스트림을 얻는 방법은 무엇입니까?

1열

1답변

Blocking I/O 작업을위한 ParallelFlux 대 flatMap()

차단 작업 (네트워크 호출, 응답 대기 필요)이 포함 된 Project Reactor 체인이 있습니다. 여러 차단 작업을 동시에 실행하고 싶습니다. 그것은, 베어 뼈 예 사용될 수) ParallelFlux 또는 flatMap (하나처럼 보인다 : Flux.just(1) .repeat(10) .parallel(3) .runOn(Sc

0열

1답변

RxJava 2.0에서 Reactive-Streams 프로세서 사용

RxJava 2.0에서 사용하고자하는 org.reactivestreams.Processor이 있습니다. 그러나 org.reactivestreams.Publisher을 io.reactivex.Flowable#fromPublisher과 같이 RxJava와 통합하는 변환이 있지만 org.reactivestreams.Processor (또는 org.reactive

1열

1답변

데이터베이스에 반응적인 API 제공

스트리밍을 지원하지 않는 데이터베이스에 대해 재 활성화 스트림 API를 어떻게 제공합니까? 예를 들어 dynamodb를 예로들 수 있습니다. get 호출을 할 때, dynamodb는 모든 결과를 반환 할 것입니다. 따라서 Source에서 get 호출을 감싸더라도 하위 단계의 배압은 어떻게 처리합니까? 또한 db에 쓰기 호출을 구현하는 방법은 무엇입니까? 내

3열

1답변

여러 개의 JVM이 포함 된 Akka 스트림에서 백 프레셔를 유지하는 방법

Akka 2.4.16부터 리 액티브 스트림의 "원격"구현은 없다는 것을 알고 있습니다. 이 사양은 단일 JVM에서 실행되는 스트림에 중점을 둡니다. 그러나 배후 압력을 유지하면서 일부 처리를 위해 다른 JVM을 사용하는 유스 케이스를 고려하십시오. 아이디어는 스트림을 실행하는 사용자 인터페이스를 제공하는 기본 응용 프로그램을 갖는 것입니다. 예를 들어,이

8열

1답변

RxJava 2.0 - Observable을 Publisher로 변환하는 방법

RxJava 버전 2에서 Observable을 Publisher로 변환하는 방법은 무엇입니까? 첫 번째 버전에서는 정확히 필요한 작업을 수행하는 https://github.com/ReactiveX/RxJavaReactiveStreams 프로젝트가 있습니다. 하지만 RxJava 2에서 어떻게 할 수 있습니까?

3열

2답변

Akka 리 액티브 스트림은 항상 하나의 메시지 뒤에 있습니다

어떤 이유로, 제 Akka 스트림은 항상 첫 번째 메시지를 "방출"(?)하기 전에 두 번째 메시지를 기다립니다. 다음은 내 문제를 보여주는 몇 가지 예제 코드입니다. val rx = Source((1 to 100).toStream.map { t => Thread.sleep(1000) println(s"doing $t") t })