Akka: акторы и сообщения

sealed trait Command
case class Add(value: Int) extends Command
case object Total extends Command

// Дополнительный контекст: Команда пришла повторно после перезапуска, а сообщения отправлялись из разных акторов.
sealed trait Command
case class Add(value: Int) extends Command
case object Total extends Command

sealed trait Command
case class Add(value: Int) extends Command
case object Total extends Command
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

import akka.actor.typed.ActorRef
sealed trait Command
case class Add(value: Int, replyTo: ActorRef[Done]) extends Command
case object Done
// Сообщение содержит неизменяемые данные; изменяемый буфер сюда не передаётся.

// Дополнительный контекст: Состояние актора восстановили, но очередь содержала старые команды.
import akka.actor.typed.ActorRef
sealed trait Command
case class Add(value: Int, replyTo: ActorRef[Done]) extends Command
case object Done
// Сообщение содержит неизменяемые данные; изменяемый буфер сюда не передаётся.

import akka.actor.typed.ActorRef
sealed trait Command
case class Add(value: Int, replyTo: ActorRef[Done]) extends Command
case object Done
// Сообщение содержит неизменяемые данные; изменяемый буфер сюда не передаётся.
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

import akka.actor.typed.ActorRef
sealed trait Command
case class Add(value: Int) extends Command
def send(left: ActorRef[Command], right: ActorRef[Command]): Unit =
  left ! Add(1)
  right ! Add(2)
// Между разными отправителями общего порядка доставки нет.

// Дополнительный контекст: Маршрутизатор увеличили, хотя обработчики делили один внешний ресурс.
import akka.actor.typed.ActorRef
sealed trait Command
case class Add(value: Int) extends Command
def send(left: ActorRef[Command], right: ActorRef[Command]): Unit =
  left ! Add(1)
  right ! Add(2)
// Между разными отправителями общего порядка доставки нет.

import akka.actor.typed.ActorRef
sealed trait Command
case class Add(value: Int) extends Command
def send(left: ActorRef[Command], right: ActorRef[Command]): Unit =
  left ! Add(1)
  right ! Add(2)
// Между разными отправителями общего порядка доставки нет.
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

val pool = Routers.pool(poolSize = 4)(worker)
val router = context.spawn(pool, "workers")

// Дополнительный контекст: Маршрутизатор увеличили, хотя обработчики делили один внешний ресурс.
val pool = Routers.pool(poolSize = 4)(worker)
val router = context.spawn(pool, "workers")

val pool = Routers.pool(poolSize = 4)(worker)
val router = context.spawn(pool, "workers")
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

def pureTotal(xs: List[Int]): Int = xs.sum
val input = List(10, 20, 30)
val total = pureTotal(input)
println(total)

def pureTotal(xs: List[Int]): Int = xs.sum
val input = List(10, 20, 30)
val total = pureTotal(input)
println(total)
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.