Как разделить и отправить асинхронный поток управления, используя Continuations?
У меня есть асинхронный поток управления, как показано ниже:
ActorA ! DoA(dataA, callback1, callbackOnErrorA)
def callback1() = {
...
ActorB ! DoB(dataB, callback2, callbackOnErrorB)
}
def callback2() = {
ActorC ! DoC(dataC, callback3, callbackOnErrorC)
}
...
Как бы я разделил этот поток на несколько частей (продолжений) и последовательно распределял их между различными участниками (или потоками / задачами), сохраняя общее состояние?
Любая подсказка оценена, спасибо