akka-stream

14Hitze

1Antwort

Kann mir bitte jemand erklären mir Unterschied zwischen map und mapAsync w.r.t AKKA Stream? In the documentation wird gesagt, dass Stream-Transformationen und Nebenwirkungen mit externem Nicht-Stream

6Hitze

2Antwort

Schließen akka-http websocket Verbindung vom Server

In meinem Szenario sendet ein Client "Auf Wiedersehen" Websocket-Nachricht und ich muss zuvor hergestellte Verbindung auf der Serverseite schließen. Von akka-http docs: Schließen von Verbindungen ist

5Hitze

2Antwort

Idiomatische Verwendung von Spark DStream als Quelle für einen Akka-Stream

Ich erstelle eine REST-API, die eine Berechnung in einem Spark-Cluster startet und mit einem Chunked-Stream der Ergebnisse antwortet. Wenn der Spark-Datenstrom mit Berechnungsergebnissen verwendet wir

9Hitze

2Antwort

Akka-Stream-Umsetzung langsamer als Single-Threaded-Implementierung

Update von 2015-10-30 basierend auf Roland Kuhn awnser: Akka Streams verwendet asynchrone Nachricht zwischen Akteuren vorbei zu implementieren Stream Verarbeitungsstufen. Das Übergeben von Daten über

14Hitze

1Antwort

Fehler beim Erstellen des Diagramms: Anforderung fehlgeschlagen: Die Eingänge [] und Ausgänge [] müssen den Eingängen [in] und Ausgängen [out] entsprechen

Ich verwende akka streams graphDSL, um ein lauffähiges Diagramm zu erstellen. Es gibt keine Kompilierungszeitfehler beim Ein-/Ausgang der Stream-Komponenten. Runtime löst folgenden Fehler aus: Irgendw

7Hitze

2Antwort

Warum hört dieses einfache Programm von Akka Streams niemals auf?

Sollte eine einfache Frage sein. Ich benutze Akka 2.4.2 (enthält Akka Streams & HTTP). Ich erwartete, dass Source & das Programm beendet, weil die Source endlich ist, aber es nie tut. Warum endet dies

9Hitze

2Antwort

Bedingte Überspringen von Daten mit Akka-Streams

Ich verwende Akka-Streams und ich habe ein Segment meines Graphen, das ich bedingt überspringen muss, weil der Flow bestimmte Werte nicht verarbeiten kann. Insbesondere habe ich einen Ablauf, der eine

5Hitze

3Antwort

Wie gruppieren eingehende Ereignisse aus dem unendlichen Stream?

Ich habe einen unendlichen Strom von Ereignissen: (timestamp, session_uid, traffic) heißt ... (1448089943, session-1, 10) (1448089944, session-1, 20) (1448089945, session-2, 50) (1448089946, ses

6Hitze

1Antwort

Wie kann ich eine HTTP-Ressource mit Akka Streams und HTTP in eine Datei herunterladen?

In den letzten paar Tagen habe ich versucht, herauszufinden, der beste Weg, um eine HTTP-Ressource in eine Datei mit Akka Streams und HTTP herunterladen. Zunächst begann ich mit den Future-Based Varia

5Hitze

3Antwort

akka-http chunked Antwort Verkettung

Ich benutze akka-http, um eine Anfrage an einen http-Dienst, der chunked Antwort zurücksendet. Dies ist, wie das entsprechende Bit von Code wie folgt aussieht: val httpRequest: HttpRequest = //build t