akka-stream

7Hitze

2Antwort

Angenommen, ich habe eine beliebig komplexe Flow[HttpRequest, HttpResponse, Unit] eingerichtet. Ich kann schon gesagt verwenden Fluss eingehende Anfragen bearbeiten mit Http().bindAndHandle(flow, "0.0

3Hitze

1Antwort

Kafka Nachricht an WebSocket

Ich versuche, einen Kafka-Consumer zu WebSet Flow mit reaktiven Kafka, Akka-http und Akka-Stream zu schreiben. val publisherActor = actorSystem.actorOf(CommandPublisher.props) val publisher = Act

1Hitze

1Antwort

Wie kann ich mein Akka-Streams Prime-Sieb ändern, um Modulo-Checks für bekannte Primzahlen auszuschließen?

Ich schrieb ein Sieb mit akka Strömen prime Mitglieder einer beliebigen Quelle Int zu finden: object Sieve extends App { implicit val system = ActorSystem() implicit val mat = ActorMaterial

1Hitze

1Antwort

Scala Akka Streams Merging Filter und Karte

Ich frage mich, ob es eine Möglichkeit gibt, den folgenden Scala-Code zu optimieren, weil es nicht sehr effizient aussieht. Grundsätzlich möchte ich nur ein Objekt, das kein Tweet ist, aus dem Fluss e

13Hitze

1Antwort

Wie verwende ich einen Akka Streams SourceQueue mit PlayFramework

Ich möchte eine SourceQueue verwenden, um Elemente dynamisch in eine Akka Stream Quelle zu schieben. Play Controller benötigt eine Quelle, um ein Ergebnis mit der Methode chuncked streamen zu können.

7Hitze

2Antwort

Wie werden reaktive Datenströme in Slick zum Einfügen von Daten verwendet?

In Slick's documentation Beispiele für die Verwendung von Reactive Streams werden nur zum Lesen von Daten als Mittel eines DatabasePublisher vorgestellt. Aber was passiert, wenn Sie Ihre Datenbank bas

1Hitze

1Antwort

Gruppenstrom Elemente Gewichtsfunktion in Akka Streams

Man stelle sich einen val myFlow: Flow[Element] = ... //some flow.. Bei einer Gewichtsfunktion val weightFunction: Element => Int Ich mag würde eine val transformedFlow: Flow[List[Element]] , so

3Hitze

1Antwort

In Akka Streams, wird Sink.fold() serialisiert?

Ich beginne mit Akka Streams; Ich versuche, einen Stream zu erstellen, der Daten von einem Webdienst liest und sie dann in S3 fortsetzt. Ich frage mich, wenn ich einen Sink mit der Sink.fold-Methode (

0Hitze

2Antwort

Consuming Strict und Streamed WebSocket Nachrichten in Akka

Ich experimentiere mit dem Aufbau eines Web-Socket-Service mit Akka HTTP. Ich muss Strenge Nachrichten behandeln, die vollständig ankommen, und auch gestreamte Nachrichten behandeln, die in mehreren F

1Hitze

1Antwort

Play Framework 2.5, Routen zum Web-Socket können nicht kompiliert werden

Ich versuche, meinen WebSocket Controller-Code auf Play 2.5 zu migrieren und habe die Anweisungen unter ScalaWebSockets befolgt. Ich erhalte Compilerfehler für meine Routenkonfigurationen. Mein WebSoc