backpressure

14Hitze

1Antwort

Was ist eine korrekte Möglichkeit, pipe-lesbare Datenströme von schreibbaren in nodejs anzuhalten?

Ich schreibe ein Modul, das ein beschreibbarer Stream ist. Ich möchte eine Pipe-Schnittstelle für meine Benutzer implementieren. Wenn ein Fehler auftritt, muss ich den lesbaren Stream pausieren und ei

node.js stream backpressure 2015-10-28

---

1Hitze

1Antwort

core.async toggle channel mix

Ich experimentiere mit den Mixes von core.async. Es scheint, dass das Stummschalten eines Eingangskanals in einem Mix einer der möglichen Wege zum Implementieren von Gegendruck sein könnte. Ich verwen

clojure core.async backpressure 2016-04-11

---

4Hitze

1Antwort

Spark Streaming Kafka Gegendruck

Wir haben eine Spark-Streaming-Anwendung, liest es Daten aus einer Kafka-Warteschlange im Empfänger und macht einige Transformation und Ausgabe nach HDFS. Das Batch-Intervall ist 1min, wir haben berei

apache-spark streaming apache-kafka backpressure 2016-04-15

---

2Hitze

1Antwort

Wie verarbeitet man RxJS stream n Elemente gleichzeitig und sobald ein Element fertig ist, automatisch wieder auf n zurück?

Ich habe einen Strom von Ereignissen und ich möchte eine Funktion aufrufen, die ein Versprechen für jedes dieser Ereignisse zurückgibt, das Problem ist, dass diese Funktion sehr teuer ist, also möchte

javascript rxjs backpressure 2016-07-26

---

-1Hitze

1Antwort

Wird es eine reaktive Cache-API in Play geben

Wir haben Probleme mit Play-Cache in dem die API blockiert. Gibt es irgendwelche Pläne, die jemand weiß, um in Play eine neue Cache-API zu entwickeln, die nicht nur nicht blockierend ist, sondern auch

caching playframework reactive-programming akka-stream backpressure 2016-04-21

---

0Hitze

1Antwort

Konvertieren von RxJS v4-Code in v5, Verarbeiten einer Warteschlange mit einem "Pull"

Ich habe eine "Arbeitswarteschlange", die ich beobachten/abonnieren möchte. Dies ist ein Array von zu verarbeitenden Befehlsobjekten. Neue Arbeitsaufgaben kommen typischerweise in Bursts an und sie mü

javascript rxjs observable rxjs5 backpressure 2016-08-02

---

9Hitze

1Antwort

Wo ist der Speicherverlust, wenn Mapcat den Backpressure-Druck in core.async aufhebt?

Ich schrieb etwas core.async Code in Clojure und als ich es ausführte, verbrauchte es den gesamten verfügbaren Speicher und scheiterte mit einem Fehler. Es scheint, dass die Verwendung von in einer co

asynchronous memory-leaks clojure core.async backpressure 2016-06-21

---