Suchergebnisse für Anfrage "akka-stream"
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 ...
Wie erstelle ich eine Quelle, die Elemente später über einen Methodenaufruf empfangen kann?
Ich möchte ein @ erstellSource und später Elemente darauf schieben, wie in: val src = ... // create the Source here // and then, do something like this pushElement(x1, src) pushElement(x2, src)Was ist die empfohlene Vorgehensweise? Vielen Dank
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
Seite 1 von 2