akka

2Hitze

1Antwort

Ich bin neugierig auf Akkas Java-API-Versionskonventionen, und ich kann nichts in ihren Dokumenten finden. Wenn Sie bekam Repo Maven und nach verfügbaren akka-actor Versionen suchen, werden Sie Einträ

0Hitze

1Antwort

Akka Streams erstellen neue Quelle aus dem Ergebnis der vorherigen Quelle in einem Diagramm

Ich versuche zu erstellen Graph, der 1 Eingabequelle nimmt, nimmt das letzte Element und produziert neue Quelle. Momentan habe ich das nur geschafft, indem ich den ersten Stream mit Sink.last material

0Hitze

1Antwort

Scala warten auf die Liste der Zukunft zu führen

Hallo Ich versuche, Daten in einer Datei zu verarbeiten. Dies ist der Code, den ich unten verwende. Ich habe eine Liste von Futures und versuche, die Ausgabe von diesen Futures zu bekommen. Alles ist

3Hitze

1Antwort

Akka Http Client + Load Balancer

Was ist der richtige Weg, einen Load-Balancer mit akka http zu feuern? Derzeit bin ich mit der Folge Stück Code: val poolClientFlow = Http().cachedHostConnectionPool[String](host, port) source

8Hitze

2Antwort

Wie gebe ich einen impliziten Wert für einen akka.stream.Materializer beim Senden eines FakeRequest ein?

Ich versuche, den Fehler (s), den ich unten sehe, zu verstehen und zu lernen, wie ich es beheben kann. could not find implicit value for parameter materializer: akka.Stream.Materializer val fut:

5Hitze

1Antwort

So senden Sie eine Nachricht in einem reaktiven Stream von einem Abonnenten an einen Publisher in einer Web-Socket-Verbindung

Meine Anwendung verfügt über eine Akka-Websocket-Schnittstelle. Der Web-Socket besteht aus einem Actor-Subscriber und einem Actor-Publisher. Der Abonnent behandelt Befehle, indem er sie an den entspre

1Hitze

1Antwort

Kann man mit einem entfernten Akteur von einem Nicht-Akteur kommunizieren?

Ich weiß, dass Sie Nachrichten senden können und eine Antwort von außerhalb eines Schauspielers erhalten, wenn Sie ask (? Syntax) verwenden. Das Problem ist, ich weiß nicht, ob dies getan werden kann,

6Hitze

1Antwort

wie scala falten funktioniert?

Ich versuche den folgenden Code zu verstehen, kann aber nicht. es soll einen untergeordneten Akteur für ein Ereignis schaffen, wenn es nicht existiert, andernfalls sagt er, dass das Ereignis als es ve

0Hitze

2Antwort

Wie erhalte ich den aktorRef des scheiternden Schauspielers in einem OneForOneStrategy Setup?

Wie kann ich den actorRef oder den Namen des fehlerhaften Knotens abrufen? Ich muss den Knoten neu starten, wenn die Ausnahme einmal auftritt. Wenn die Ausnahme> 1 auftritt, muss ich fortfahren. Mein

0Hitze

2Antwort

Ich muss Operationen nacheinander mit Akka ausführen

Ich habe einen Akteur, der Datenbankaktualisierungen orchestriert. Ich muss sicherstellen, dass jede Operation erst ausgeführt wird, nachdem die vorherige abgeschlossen wurde. Dies, weil Operation B d