Suchergebnisse für Anfrage "akka"
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 ...
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 ^ ...
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-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 ...
Warum verwendet Spark 1.6 kein Akka?
Wenn ich den spark-1.6-Quellcode des @ leMeiste [https://github.com/apache/spark/blob/cf2e9da612397233ae7bca0e9ce57309f16226b5/core/src/main/scala/org/apache/spark/deploy/master/Master.scala] class, die Methode receiveAndReply scheint Akka nicht ...
Akka HTTPS (SSL) Server mit ssl-conf
Akka Version: Akka 2.4.7 [https://github.com/akka/akka/tree/v2.4.7]Akka Features: HTTPS Server Support [http://doc.akka.io/docs/akka/2.4.7/scala/http/server-side-https-support.html] Typesafe ssl-config ...
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 ...
ufruf einer Methode im Spiel WebSocket in Sca
Ich bin neu bei Scala, Play Framework und Akka. Ich habe die Funktion als @ definie def socket = WebSocket.accept[String, String] { request => ActorFlow.actorRef(out => MyWebSocketActor.props(out)) } Dies möchte ich aus einer anderen Klasse ...
Java Spring als Client für Akka-basierten REST-HTTP-Aufruf
Ich muss diesen in @ geschriebenen REST-Service aufrufe scala-akka Projekt von java-spring. My Scala REST Service ist wie val route = post { path("notification" / "signUp"){ headerValueByName("App_Key") { app_key => { handleWith { ...
Akka Persistence Query Event Stream und CQRS
Ich versuche, die Leseseite in meine ES-CQRS-Architektur zu implementieren. Nehmen wir an, ich habe einen hartnäckigen Schauspieler wie diesen: object UserWrite { sealed trait UserEvent sealed trait State case object Uninitialized extends State ...