akka-stream

10Hitze

1Antwort

Kann jemand klar erklären, was der Unterschied zwischen diesen 4 Methoden ist? Wann ist es sinnvoller, jeden zu verwenden? Und wie heißt diese Methodengruppe? Gibt es mehr Methoden, die den gleichen J

0Hitze

1Antwort

Akka Stream stoppt nach einem Element

Mein Akka Stream stoppt nach einem einzelnen Element. Hier ist mein stream: val firehoseSource = Source.actorPublisher[FirehoseActor.RawTweet]( FirehoseActor.props( auth = ... ) ) val ref

1Hitze

2Antwort

Materialisieren eines Graphen innerhalb eines Schauspielers

Ich versuche, ein Diagramm innerhalb eines Schauspielers zu materialisieren. Dies scheint zu funktionieren, wenn eine der folgenden Bedingungen erfüllt sind: Der Graph enthält keine Broadcast (erstell

0Hitze

1Antwort

Akka HTTP-Client akka-http akka-http-jackson

Ich versuche, einen Schauspieler ruft eine einfache GET auf Rest-Service. Dafür verwende ich akka-http-experimental_2.11 und akka-http-jackson-experimental_2.11. Versuchen Sie, wie ich könnte ich nich

13Hitze

1Antwort

Datei-Upload mit Akka HTTP

Ich versuche, Datei-Upload-Funktionalität in meiner Anwendung mit Akka HTTP zu implementieren. Ich verwende akka-stream Version 2.4.4. Hier ist der Code (modifiziert nach akka-doc) path("fileupload")

5Hitze

1Antwort

Akka-Stream - Setzen eines IO-gebundenen Flusses auf einen anderen Dispatcher

Mein Stream hat eine gleichmäßige Mischung aus CPU-gebundenen und IO-gebundenen Stufen (jeder IO-Stufe folgt eine CPU-Stufe). Ich möchte die IO-Operationen auf einen anderen Dispatcher als den Rest de

2Hitze

1Antwort

Wie kann SSL mit einem TCP-Client in Akka 2.4.6 eingerichtet werden?

Ich versuche, eine TCP-Verbindung auf TLS einzurichten, kann jedoch keine aktuelle Dokumentation dazu finden. I found something about Akka streams 2.2 hat es geschafft, etwas für 2.4.x zu finden. Ich

0Hitze

2Antwort

Akka Streams TCP-Socket-Client-Seite Beendigung

Ich habe folgende flow: val actorSource = Source.actorRef(10000, OverflowStrategy.dropHead) val targetSink = Flow[ByteString] .map(_.utf8String) .via(new JsonStage()) .map { json =>

5Hitze

3Antwort

Akka Streams: Mehrere Dateien lesen

Ich habe eine Liste von Dateien. Ich möchte: Um von allen von ihnen als eine einzige Quelle zu lesen. Dateien sollten der Reihe nach nacheinander gelesen werden. (kein Round-Robin) Zu keinem Zeitpunkt

12Hitze

1Antwort

Akka Streams. Stateful state in a flow

Ich möchte mehrere große Dateien mit akka Streams lesen, um jede Zeile zu verarbeiten. Stellen Sie sich vor, dass jeder Schlüssel aus einem ("Bezeichner" -> "Wert") besteht. Wenn ein neuer "Bezeichner