У меня есть немного путаницы с веером стратегий в Akka streams, я прочитал, что Broadcast - (1 вход, N выходов), данные входной элемент испускает к каждому выходу, а Balance - (1 вход, N выходов), есл
Я читаю файл csv. Я использую потоки Akka для этого, чтобы создать график действий для каждой строки. У меня есть следующий пример игрушек. def main(args: Array[String]): Unit = {
implicit val sy
Допустим, у меня есть печь для пиццы и линия пиццы, которую мне нужно испечь. Моя духовка имеет только возможность выпекать 4 пиццы за раз, и разумно ожидать, что в течение дня в очереди всегда будет
Я пытаюсь проверить пропускную способность Akka Streams и посмотреть, насколько она масштабируется по мере увеличения количества запросов. Проблема, с которой я столкнулся сейчас, заключается в том, ч
Если узел выходит из строя и в этот момент сообщения помещаются в очередь в почтовом ящике, тогда как эти сообщения будут переработаны? Если они не могут быть переработаны, то как мы можем сказать, чт