Suchergebnisse für Anfrage "akka"
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 ...
getting status -1 anstatt 401 Angularjs
Ich versuche eine Antwort vom Server zu bekommen. Die Funktion sieht so aus: function getOverview() { var req = { method: 'GET', url: base, headers: { 'authorization': 'Bearer ' + GottenTokens.getSessionToken() } }; return $http(req).then( ...
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 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 Sie diesen Code mithilfe von Akka-Streams umgestalten können.
Die Idee ist, den Kanal geöffnet zu lassen, um ihn später zu verwenden. In playframework 2.5.x heißt es in der Dokumentation, dass Sie Akka-Streams verwenden müssen, ohne zu sagen, wie Sie dieses Beispiel erreichen können. Kann mir jemand ...
Akka Future - Parallel versus Concurrent?
Aus dem gut geschriebenenAkka Concurrency [http://www.artima.com/shop/akka_concurrency]: [/imgs/xFnqg.png] WieIch versteh, das Diagramm zeigt, beidenumSummer undcharConcat wird auf demselben Thread ausgeführt. Ist es möglich, jedes @ ...
Wie rufe ich einen einzelnen Server von mehreren Akteuren / Web-Handlern mit Akka HTTP richtig auf?
Ich habe einen Service (nennen wir ihn Service A), der über Akka Server HTTP eingehende Anfragen bearbeitet. Außerdem habe ich eine Drittanbieteranwendung (Service B), die mehrere Webdienste bereitstellt. Der Zweck von Service A besteht darin, ...
Wie verspotte ich einen Akka-Schauspieler beim Unit-Test einer Klasse?
Ich habe eine Controller-Klasse, die die Anforderungen steuert, die an einen Akka-Akteur gesendet werden, der in den Controller eingespeist wird. Controller-Code: class Controller(actor: ActorRef) { def control(msg: String): Future[String] = ...
Akka TCP Client: Wie kann ich mit akka actor @ eine Nachricht über TCP sende
Ich möchte Textnachrichten über TCP senden. Ziemlich einfach. Das möchte ich mit akka machen. Ich habe diesen Artikel über akka IO ...