Inkrementelle Verarbeitung in einem Akka-Schauspieler

Ich habe Schauspieler, die sehr langwierige und rechenintensive Arbeit leisten müssen, aber die Berechnung selbst kann inkrementell erfolgen. Während die vollständige Berechnung selbst Stunden in Anspruch nimmt, sind die Zwischenergebnisse tatsächlich äußerst nützlich, und ich möchte in der Lage sein, auf alle Anfragen von ihnen zu antworten. Dies ist der Pseudocode für das, was ich tun möchte:

var intermediateResult = ...
loop {
     while (mailbox.isEmpty && computationNotFinished)
       intermediateResult = computationStep(intermediateResult)


     receive {
         case GetCurrentResult => sender ! intermediateResult
         ...other messages...
     }
 }

Antworten auf die Frage(4)

Ihre Antwort auf die Frage