Wie kann ein asynchroner Kontrollfluss mithilfe von Fortsetzungen aufgeteilt und verteilt werden?
Ich habe einen asynchronen Kontrollfluss wie den folgenden:
ActorA ! DoA(dataA, callback1, callbackOnErrorA)
def callback1() = {
...
ActorB ! DoB(dataB, callback2, callbackOnErrorB)
}
def callback2() = {
ActorC ! DoC(dataC, callback3, callbackOnErrorC)
}
...
Wie würde ich diesen Fluss in mehrere Teile (Fortsetzungen) aufteilen und diese nacheinander an verschiedene Akteure (oder Threads / Aufgaben) weiterleiten, während der Gesamtzustand erhalten bleibt?
Jeder Hinweis dankbar, danke