backpressure

1열

1답변

관찰 가능한 요소를 올바른 (실제) 시간에 전달하는 방법은 무엇입니까?

생각에는 좀 노선이 로봇을 의미 public static double[][] points = new double[][]{ {0, 0}, {0, 10}, {1, 10}, {1, 0}, {0, 0} }; public static Observable<double[]> routePoints(

java rx-java reactive-programming backpressure 2017-02-06

---

1열

1답변

cassandra에서 EC2 스 니치 구성을 실행하는 방법

Ec2 스 니치 구성에서 단일 cassandra 노드를 시작하려고합니다. 나는이 구성 변경된 YAML 속성은 다음과 같습니다 seeds : 'ip-address of machine' listen: 'ip_address of machine' rpc_address:'ip_address of machine' snitch : Ec2Snitch 다른 모든

c amazon-ec2 yaml cassandra-3.0 backpressure 2017-12-04

---

0열

1답변

리소스 부족으로 볼 수있는 역압

RxJava 1/RxScala에서 다음 상황에서 관찰 할 수있는 소스를 어떻게 조절할 수 있습니까? def fast: Observable[Foo] // Supports backpressure def afterExpensiveOp: Observable[Bar] = fast.flatMap(foo => Observable.from(expensiveO

scala rx-java reactive-programming rx-scala backpressure 2016-11-09

---

0열

1답변

BackPressure 적절한 연산자를 적용한 후에도 RxJava 코드에서 예외가 발생합니다.

내 안드로이드 응용 프로그램에서 RxJava를 사용하고 있습니다. interval() 함수를 사용하여 타이머를 사용하고 있지만 onBackPressureDrop()을 추가 했더라도 누락 된 Backpressure 예외가 발생합니다. 내 가입자에게 onError()를 추가했고 Crashlytics에 예외를 기록했지만 여전히 충돌합니다. 도와주세요. 나는 문제

java android exception rx-java backpressure 2016-09-22

---

0열

1답변

Sharded 액터로 보낼 때 ReactiveKafka에 대한 역압

나는 Kafka에서 입력을 받아 Shard 된 액터로 데이터를 처리하고 Kafka로 출력하는 Akka 애플리케이션을 작성했습니다. 그러나 어떤 경우에 분산됩니다 영역은 부하를 처리 할 수없는, 내가 얻을 : 당신은 아마 원격 연결을 홍수 방지하기 위해 흐름 제어를 구현해야합니다 . 이 체인/플로우에 어떻게 백 프레셔를 구현할 수 있습니까? 카프카 소비자 -

akka apache-kafka actor reactive backpressure 2017-04-10

---

0열

1답변

관찰 가능한 지원 리액턴트 풀

저는 꽤 기본적인 질문이라고 생각하며 잠시 고생했습니다. 저는 Flowable이 있는데, 이는 네트워크에서 항목 묶음을 검색하여 방출합니다. Flowable .create(new FlowableOnSubscribe<Item>() { @Override public void subscribe(FlowableEmitter<Item>

rx-java reactive-programming rx-java2 backpressure 2017-02-28

---

0열

1답변

RxJava2를 사용하여 생성 기능을 사용하여 플로팅 가능 만들기

backpressure가 구현 된 맞춤형 Flowable을 생성해야합니다. 나는 일종의 페이징을 달성하려고 노력하고있다. 즉, 다운 스트림이 5 개 항목을 요청할 때 항목 0 - 5를 "데이터 소스에 요청"합니다. 그러면 다운 스트림이 5가 더 필요할 때 항목 5 - 10을 가져와 다시 내보냅니다. 내가 지금까지 찾은 가장 좋은 것은 Flowable.gen

java kotlin observable rx-java2 backpressure 2017-11-09

---

3열

1답변

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

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

scala akka-stream reactive-streams backpressure akka-remoting 2017-01-18

---

3열

1답변

배압의 영향을받지 않는 소스를 만드는 방법

conflate과 같은 Akka 스트림 기능을 테스트하고 싶습니다. 이를 위해 간단한 단위 테스트에서 배압의 영향을받지 않는 소스를 구성해야합니다. 순진한 시도는 기압으로 인해 작동하지 않습니다. Source.tick(1.milli, 1.milli, "tick").map(_ => Random.nextDouble()) HTTP를 거쳐가는 OTOH는 아마도

scala akka akka-stream backpressure 2017-05-03

---

3열

1답변

Rxjava에서 '역압'이란 무엇입니까?

저는 RxJava의 초보자입니다. "BackPressure"의 의미에 대해 궁금합니다. 생산자가 소비자의 뒤를 압박한다는 의미입니까? 소비자가 생산자에게 압력을 가하고 있다는 뜻입니까? 당신이 항목을 방출하는 관측이있을 때

backpressure 2017-10-01

---