akka

8Hitze

1Antwort

Ich versuche herauszufinden, die beste Möglichkeit, eine echte Websocket-App mit akka-http und akka-Streams zu implementieren. Wonach ich meistens suche, ist Einfachheit, die ich jetzt gerade nicht be

1Hitze

2Antwort

scala - Wie man eine Aufgabe jeden Tag eine 11PM

Mit playframework, versuche ich, eine Funktion auszuführen, um eine Mail jeden Tag um 11 Uhr zu senden, aber ich weiß nicht, wie zu tun ist. Ich fand viele Antworten auf das Internet, aber ich habe es

2Hitze

1Antwort

Wie würden Sie viele unabhängige Graphen "verbinden", die den Gegendruck zwischen ihnen aufrechterhalten?

Kontinuierliche Reihe von Fragen über akka-streams Ich habe ein anderes Problem. Variablen: Einzel http Client Flow mit Mehrere andere Strömungen Drosselung, die zuerst gleichzeitig verwenden möchten

0Hitze

1Antwort

Akkalautsprecher (Scala) So erhalten Sie einen Heapspeicherauszug aus dem Speicher

Konfigurieren der Akka-Anwendung zum Generieren des Heap-Dumps bei Absturz (aus dem Speicher entfernt). Versuchte Suche, konnte jedoch die Informationen nicht finden. Kann mir jemand dabei helfen?

7Hitze

2Antwort

Akka Persistence Query Ereignisstrom und CQRS

Ich versuche, Lese-Seite in meiner ES-CQRS-Architektur zu implementieren. Lassen Sie sich sagen, dass ich einen persistenten Schauspieler wie diese: object UserWrite { sealed trait UserEvent

0Hitze

1Antwort

Reihenfolge der ActorContext Änderungen

Ich bemerkte, dass Schauspieler zuerst Nachricht über Zustandsänderung gesendet und später wirklich diesen Zustand geändert hat. Es ist richtig? class MyActor extends Actor { def receive = idle(S

0Hitze

1Antwort

Akka-HTTP-Wiederherstellung von der Zurückweisung (für HTML5-Verlauf api-Routing)

Ich versuche, mein Front-End von Akka-HTTP (2.4.7) zugänglich zu machen. Obwohl alles gut mit regulären Routen funktioniert, kann ich nicht herausfinden, wie HTML5 PushState-Unterstützung aktiviert wi

4Hitze

1Antwort

Gibt es einen Grund für die Abwertung der Shutdown-Methode?

Beim Herunterfahren eines ActorSystems habe ich festgestellt, dass ActorSystem::shutdown veraltet war. Es wird vorgeschlagen, "Use the terminate() method instead". Aber die decumentation dieser Method

3Hitze

2Antwort

Akka Reactive Streams immer eine Nachricht hinter

Aus irgendeinem Grund warten meine Akka-Streams immer auf eine zweite Nachricht, bevor sie den ersten "ausstrahlen" (?). Hier ist ein Beispiel Code, der mein Problem zeigt. val rx = Source((1 to 100).

2Hitze

1Antwort

Ist es möglich, auf scalas akka ByteString ein Muster zu finden?

Ich bin ein selbstdefinierte TCP-Protokoll mit here class SimplisticHandler extends Actor { import Tcp._ def receive = { case Received(data) => sender() ! Write(data) case PeerClos