akka-stream

0Hitze

1Antwort

Abspielen 2.5 ActorFlow: kann nicht von Flow konvertiert werden <String, String, # 1-of?> In Flow <String, String,?>

Während der Migration zu Play 2.5 versuche ich, die neue WebSocket-Funktionalität wie beschrieben zu implementieren here (Umgang mit WebSockets mit Akteuren). In Play 2.5.4 gibt es kein play.libs.stre

3Hitze

2Antwort

Wie man einen akka-Strom abrupt stoppt Runable Graph?

Ich bin nicht in der Lage, herauszufinden, wie akka stream Runnable Graph sofort zu stoppen? Wie benutzt man Killswitch um das zu erreichen? Ich habe erst ein paar Tage mit Akka Streams angefangen. In

8Hitze

1Antwort

Akka Streams Websocket Wiring

Ich versuche herauszufinden, die beste Möglichkeit, eine echte Websocket-App mit akka-http und akka-Streams zu implementieren. Wonach ich meistens suche, ist Einfachheit, die ich jetzt gerade nicht be

2Hitze

1Antwort

Wie würden Sie viele unabhängige Graphen "verbinden", die den Gegendruck zwischen ihnen aufrechterhalten?

Kontinuierliche Reihe von Fragen über akka-streams Ich habe ein anderes Problem. Variablen: Einzel http Client Flow mit Mehrere andere Strömungen Drosselung, die zuerst gleichzeitig verwenden möchten

2Hitze

1Antwort

Wie eine Akka Stream-Quelle [Seq [A]] von Quelle [A]

mit früheren Versionen von Akka Streams erstellen, groupBy ein Source von Source s zurück, die in ein Source[Seq[A]] verwirklicht werden könnte. Mit Akka Streams 2.4 sehe ich, dass groupBy eine zurück

3Hitze

2Antwort

Akka Reactive Streams immer eine Nachricht hinter

Aus irgendeinem Grund warten meine Akka-Streams immer auf eine zweite Nachricht, bevor sie den ersten "ausstrahlen" (?). Hier ist ein Beispiel Code, der mein Problem zeigt. val rx = Source((1 to 100).

10Hitze

1Antwort

Ordnungsgemäße Art, Akka-Streams zu stoppen

Ich habe erfolgreich FileIO verwendet, um den Inhalt einer Datei zu streamen, einige Transformationen für jede Zeile zu berechnen und die Ergebnisse zu aggregieren/zu reduzieren. Jetzt habe ich einen

2Hitze

1Antwort

Akka-Stream - Liste zu mapAsync einzelner Elemente

Mein Stream hat einen Flow, dessen Ausgaben List [Any] -Objekte sind. Ich möchte eine mapAsync gefolgt von einigen anderen Phasen haben, von denen jede ein einzelnes Element anstelle der Liste verarbe

1Hitze

2Antwort

Akka Stream - Timer oder Scheduler wie CRON

Ich benutze Akka Stream auf Scala. Ich möchte einen Scheduler einstellen, der auf jeder 24:00 läuft. Ich habe versucht, danach zu suchen. Aber ich konnte nicht finden, was ich machen möchte. Können Si

3Hitze

1Antwort

Akka-Streams - Wie nehme ich den materialisierten Wert der Quelle, die in einer anderen Quelle flamMapConcatenated ist?

Ich versuche, eine Quelle [Out, Mat] aus einer Zukunft [Quelle [Out, Mat]] zu erstellen und verwendete dazu die integrierte source.fromFuture in Kombination mit flatMapConcat. Bei Verwendung von fromF