Suchergebnisse für Anfrage "akka-stream"
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 ...
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 / ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ^ ...
Akka Stream + Akka Http - Anfrage bei Fehler abrufen
Ich habe den folgenden Stream, der ziemlich gut funktioniert: source .map(x => HttpRequest(uri = x.rawRequest)) .via(Http().outgoingConnection(host, port)) .to(Sink.actorRef(myActor, IsDone)) .run() und ein einfacher Akteur, der den ...
Wie werden reaktive Streams in Slick zum Einfügen von Daten verwendet?
Im Slicks Dokumentation [http://slick.typesafe.com/doc/3.1.1/dbio.html#streaming] Beispiele für die Verwendung von Reactive Streams werden nur zum Lesen von Daten als Mittel für einen DatabasePublisher vorgestellt. Aber was passiert, wenn Sie ...
Seite 1 von 2