akka-stream

0Hitze

1Antwort

Ich versuche, den folgenden Code auszuführen, basierend auf der akka Strom Kurzanleitung: implicit val system = ActorSystem("QuickStart") implicit val materializer = ActorMaterializer() val songs =

1Hitze

1Antwort

Erste Schritte mit Akka Streams

Ich habe in den letzten Tagen über Akka Streams gelesen und arbeite seit ein paar Monaten mit Rx Bibliotheken in Scala. Für mich scheint es einige Überschneidungen zu geben, was diese beiden Bibliothe

2Hitze

1Antwort

Behandeln von HTTPS-Anforderungen mit Akka-http [Java]

Ich erstellte einen kleinen Proxy, um alle lokalen HTTP-Anforderungen abzufangen, und autorisierte sie dann mit dem Remote-Proxy. Hier ist das Code-Snippet: Source<IncomingConnection, CompletionStage<

-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

3Hitze

1Antwort

Akka-Stream + Akka Http - Get Antrag auf Fehler

Ich habe folgenden Strom, der ziemlich gut funktioniert: source .map(x => HttpRequest(uri = x.rawRequest)) .via(Http().outgoingConnection(host, port)) .to(Sink.actorRef(myActor, IsDone)

0Hitze

1Antwort

So erstellen und starten Sie einen Akka-Stream in einem Stream

Ich habe einen akka-Stream, der einige Nachrichten verarbeitet. Wenn ein Ereignis auftritt, sollte der Stream eine neue Instanz eines anderen akka-Streams erstellen. Momentan mache ich das gerade. Ist

2Hitze

1Antwort

Eine Quelle zu vielen sinken mit Akka Streams

Ich probiere einige Sachen mit Akka Streams für eines meiner Projekte, wo ich bereits Rx Scala verwenden. Ich war versucht zu sehen, wie Akka Streams die Rx Scala-Bibliothek, die wir haben, ersetzen k

0Hitze

1Antwort

Akka Stream - Parallel lauffähige Graphen

Brauchen Sie Vorschlag, ich muss parallel mehrere Quelldiagramme ausführen, zum Beispiel habe ich diesen Beispielcode erstellt, wo ich 10 Grafiken erstellen und parallel ausführen. Ist das der richtig

2Hitze

2Antwort

Akka Stream Quelle - Cassandra Resultset

Wenn ich eine große Ergebnismenge von einer Cassandra-Abfrage habe. Gibt es eine Möglichkeit, dieses Ergebnis als Quelle eines Akka-Streams festzulegen, damit ich jede Zeile verarbeiten kann? Dank

5Hitze

1Antwort

Wie effektiv lesen Millionen von Zeilen von Cassandra?

Ich habe eine schwere Aufgabe, von einer Cassandra-Tabelle Millionen von Zeilen zu lesen. Eigentlich enthält diese Tabelle 40 bis 50 Millionen Zeilen. Die Daten sind eigentlich interne URLs für unser