При использовании потоков akka я хочу перенаправить свой поток, когда исходный поток становится медленнее.
По сути, у меня есть поток поиска, который может возвращать значение; если это не удается, поток использует поток выборки.
Но я также хочу использовать поток выборки при обратном давлении для потребителя из поиска.
Это выглядит так:
Lookup ~> Return
Lookup ~> Fetch ~> Return
Fetch ~> Return (when lookup is slow)
Каков был бы правильный способ справиться с этим? Благодаря.