Suchergebnisse für Anfrage "akka-stream"
Akka Flow bleibt hängen, wenn http-Anforderungen über den Verbindungspool gesendet werden
Ich verwende Akka 2.4.4 und versuche, von Apache HttpAsyncClient zu wechseln (erfolglos). Below ist eine vereinfachte Version des Codes, den ich in meinem Projekt verwende. Das Problem ist, dass es hängt, wenn ich mehr als 1-3 Anfragen an den ...
Wie kann ich beim Senden einer FakeRequest einen impliziten Wert für einen akka.stream.Materializer angeben?
Ich versuche, die unten angezeigten Fehler zu verstehen und zu lernen, wie sie behoben werden können. could not find implicit value for parameter materializer: akka.Stream.Materializer val fut: Future[Result] = action.apply(fakeRequest).run ^ ...
So senden Sie eine Nachricht in einem reaktiven Stream von einem Abonnenten an einen Herausgeber in einer Web-Socket-Verbindung
Meine Anwendung verfügt über eine Akka-Websocket-Schnittstelle. Der Web-Socket besteht aus einem Schauspieler-Abonnenten und einem Schauspieler-Verleger. Der Teilnehmer handhabt Befehle, indem er sie an den entsprechenden Akteur sendet. Der ...
akka-stream - Wie man das letzte Element eines Streams in einem Flow / Graph anders behandelt
Ich versuche Akka Streams zu implementierenFlow konvertiert einen Stream von JSON-Objekten in einen Stream eines einzelnen Arrays von JSON-Objekten. Ich kann nutzenConcat, um ein "[" vor und "]" nach sowie @ hinzuzufügZip, um Kommas zwischen die ...
Wie füge ich einer vorhandenen Grafik dynamisch eine Quelle hinzu?
Was kann eine Alternative zu einer sich dynamisch ändernden laufenden Grafik sein? Hier ist meine Situation. Ich habe Diagramm, das Artikel in DB einnimmt. Artikel kommen aus 3 Plugins in verschiedenen Formaten. Somit habe ich mehrere Flüsse val ...
Proper Weg, um Akka Streams unter der Bedingung zu stoppen
Ich habe erfolgreich @ verwend FileIO [http://doc.akka.io/api/akka/2.4/?_ga=1.140568374.588201913.1464855311#akka.stream.scaladsl.FileIO$] um den Inhalt einer Datei zu streamen, berechnen Sie einige Transformationen für jede Zeile und ...
TCP-Stream verbrauchen und auf einen anderen Sink umleiten (mit Akka Streams)
Ich versuche mit Akka 2.4.3 einen TCP-Stream auf einen anderen Sink umzuleiten / weiterzuleiten. Das Programm sollte einen Server-Socket öffnen, auf eingehende Verbindungen warten und dann den TCP-Stream verbrauchen. Unser Absender erwartet / ...
Wie verwende ich Akka-HTTP-Client-Websocket? Nachricht senden
Ich versuche es mit clientseitigem Websocket, indem ich doc unter @ folg webSocketClientFlow [http://doc.akka.io/docs/akka/2.4/scala/http/client-side/websocket-support.html#webSocketClientFlow] . sample code is: import akka.actor.ActorSystem ...
Seite 2 von 2