Suchergebnisse für Anfrage "akka-stream"
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 ...
Wie verwende ich eine Akka Streams SourceQueue mit PlayFramework?
Ich möchte eine SourceQueue verwenden, um Elemente dynamisch in eine Akka Stream-Quelle zu verschieben. Der Play Controller benötigt eine Quelle, um ein Ergebnis über das @ -Zeichen streamen zu könnechuncked Methode As Play verwendet einen ...
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 ...
Auf das zugrunde liegende ActorRef eines von Source.actorRef @ erstellten Akka-Streams zugreif
Ich versuche das @ zu benutz Source.actorRef [http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-RC3/?_ga=1.155309435.1917589872.1429296441#akka.stream.scaladsl.Source$] Methode zum Erstellen eines ...
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 ...
Holen Sie sich den gesamten HttpResponse-Body als String mit Akka-Streams HTTP
Ich versuche zu verstehen, wie man das neue @ benutakka.http Bibliothek. Ich möchte eine http-Anfrage an einen Server senden und den gesamten Antworttext als einzelnen String lesen, um ein @ zu erzeugeSource[String,?]. Hier ist die beste ...
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 ...
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 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 ...
Akka-Stream-Implementierung langsamer als Single-Thread-Implementierung
UPDATE FROM 2015-10-30 based on Roland Kuhn Awnser: Akka Streams verwendet asynchrone Nachrichtenübermittlung zwischen Akteuren, um Stream-Verarbeitungsstufen zu implementieren. Das Übergeben von Daten über eine asynchrone Grenze hat einen ...
Seite 1 von 2