backpressure

0Hitze

1Antwort

Rückstau zu ReaktivKafka beim Senden an geschärfte Darsteller

Ich habe eine Akka-Anwendung geschrieben, die Eingaben von Kafka nimmt und dann die Daten mit sharded Aktoren verarbeitet und an Kafka ausgibt. Aber in einigen Fällen die sharded Regionen die Last nic

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

---

0Hitze

1Antwort

Gegendruck in einem Spring DeferredResult + Akka Schauspieler Anwendung

Ich denke daran, eine Kette von Akka-Mitarbeitern zu verwenden, um einen Workflow in einer DeferredResult-basierten Spring MVC-Webanwendung zu modellieren. Im Wesentlichen wird der Controller einen De

spring spring-mvc akka backpressure deferred-result 2017-12-19

---

0Hitze

1Antwort

Observable unterstützende reaktive Pull

Ich habe seit einiger Zeit mit etwas kämpfen, was ich glaube, ist eine ziemlich grundlegende Frage. Ich habe eine Flowable, die ein Bündel von Elementen aus dem Netzwerk abruft und sie ausgibt. Flowab

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

---

0Hitze

1Antwort

Erstellen Sie eine fließende mit generate-Funktion mit RxJava2

Ich muss eine benutzerdefinierte Flowable mit Gegendruck implementiert werden. Ich versuche eine Art Paging zu erreichen. Das heißt, wenn Downstream 5 Items anfordert, werde ich die Datenquelle nach d

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

---

2Hitze

1Antwort

Akka Streams' ActorPublisher als Quelle für Web-Reaktion - wie Gegendruck arbeitet

Ich benutze akka Ströme "ActorPublisher Schauspieler als ein Streaming-per-Verbindung Source von Daten auf einen eingehenden WebSocket oder HTTP-Verbindung gesendet werden. ActorPublishercontract ist

scala akka akka-http akka-stream backpressure 2017-06-13

---

4Hitze

1Antwort

RxJava2 Observable Gegendruck

vor kurzem habe ich festgestellt, dass ich nicht verstehe, wie RxJava2 Gegendruck funktioniert. ich klein Test, und ich erwarte, dass es mit MissingBackpressureException Ausnahme fehlschlagen sollte:

java rx-java rx-java2 backpressure 2017-06-21

---

3Hitze

1Antwort

Was bedeutet "Gegendruck" in Rxjava?

Ich bin ein Anfänger von RxJava. Ich bin neugierig auf die Bedeutung von "BackPressure". Bedeutet das, dass der Produzent dem Verbraucher den Rücken freihält? Oder bedeutet es, dass die Verbraucher Dr

backpressure 2017-10-01

---

1Hitze

1Antwort

Staudruck für Akka Sharding mit persistenten Schauspielern

Gibt es ein Akka-Stream-Back-Pressure-Modell oder etwas für akka shardings mit persistentem Schauspieler? Da ich ein Problem habe, habe ich ein akka sharding Cluster mit persistenten Akteuren. (mit Ca

scala akka akka-stream akka-persistence backpressure 2017-06-27

---

4Hitze

1Antwort

Wie Spark Structured Streaming Backpressure behandelt?

Ich analysiere die Rückstaufunktion bei Spark Structured Streaming. Kennt jemand die Details? Ist es möglich, eingehende Datensätze nach Code abzustimmen? Danke

apache-spark structured-streaming backpressure 2017-07-02

---

0Hitze

1Antwort

BackPressure Ausnahme in RxJava-Code auch nach dem richtigen Operator

Ich benutze RxJava in meiner Android-Anwendung. Ich benutze einen Timer mit der Funktion interval(), aber ich bekomme eine Missing Backpressure Ausnahme, obwohl ich onBackPressureDrop() hinzugefügt ha

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

---