나는 완료하려고하는 작업에 대한 간단한 예제로 작업 중입니다. 작업 목록 (tasks)을 마다 1 초마다 트리거하려고한다고 가정 해 봅시다.. scheduler 또는 무엇이든 사용할 수 있습니다. 지금이 스트림의 두 소비자 하지만 C1이 모든 작업의 모든 n 번째 완료에 트리거해야 모든 작업 C2의 완료에 트리거해야 있습니다. (N 초마다 가능) 다음은
Using monix Observable [Node]를 구축하고 너비가 큰 첫 번째 알고리즘을 사용하여 그래프를 탐색하려고합니다. 그러나 거기에 약간의 재귀 문제가 있습니다. 다음은 내 문제를 보여주는 스 니펫입니다. package gp
import monix.eval.Task
import monix.execution.Scheduler.Implicit
실제로 Scala를 사용하고 있지만 질문은 모든 Rx 및 스트리밍 프레임 워크에 일반적입니다. 내 유스 케이스는 생성 된 관찰 가능 (따라서 콜드)이며 다중 소비자가 정확히 동일한 값을 병렬로 소비하기를 원하지만, 상당히 다른 처리량을 기대합니다. 내가 관찰 할 수있는 것은 재생 가능으로 방송 할 수 있지만 최대 버퍼 크기로 재생하는 일반적인 정책은 오버플
Monix 작업을 사용하고 있고 Throwable을 catch하고 사용자 지정 오류로 변환하려고합니다. 나는 간단하고 관련성이 있도록 코드를 제거/변경했다. 이것은 (질문이 코드 후 다음) 코드입니다 : import io.netty.handler.codec.http.HttpRequest
import monix.reactive.Observable
impo