Suchergebnisse für Anfrage "akka-stream"
Custom Supervision.Decider fängt keine Ausnahme ab, die von ActorPublisher @ erzeugt wur
Ich baue eine Bibliothek auf, die von Drittanbietern verwendet wird. Bei einer meiner Methoden gebe ich @ zurüStream[Item] das asynchron aus dem Ergebnis eines paginierten REST-API-Aufrufs generiert wird. Ich verwende meine Änderung von ...
Warum endet der Akka-Streams-Zyklus nicht in dieser Grafik?
Ich möchte ein Diagramm erstellen, das sich n-mal wiederholt, bevor es untergeht. Ich habe gerade ein Beispiel erstellt, das meine Anforderungen erfüllt, aber nicht nach dem Untergang endet, und ich verstehe wirklich nicht, warum. Kann mich ...
Wie schränke ich ein, dass ein Akka Stream nur einmal pro Sekunde ausgeführt und gesendet wird?
Ich habe einen Akka-Stream und möchte, dass der Stream ungefähr jede Sekunde Nachrichten nach unten sendet. Ich habe zwei Möglichkeiten ausprobiert, um dieses Problem zu lösen. Die erste Möglichkeit bestand darin, den Produzenten zu Beginn des ...
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 ...
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 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 ...
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 ...
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 1 von 2