Jak ograniczyć wiadomości aktora do określonych typów?

W Scali stdlib był pretekst do robienia podstawowych aktorów nieopisanych (co nie dotyczy Akki, bo nie obsługuje zagnieżdżonych odbiorników, o ile pamiętam). Winda z kolei wspiera typowanych aktorów.

Jednak, używając kanałów, nadal możliwe jest tworzenie silnie wpisanych aktorów za pomocą stdlib:

object TypedActor {

  def apply[A](fun: PartialFunction[A, Any]): OutputChannel[A] = {
    val sink = new SyncVar[Channel[A]]
    actor {
      val in = new Channel[A](self)
      sink set in
      loop {
        in react { case any => reply(fun(any)) }
      }
    }
    sink.get
  }

}

sealed abstract class FooMessage
case object Foo extends FooMessage
case object Bar extends FooMessage

object Test {

  val fooActor = TypedActor[FooMessage]{
    case Foo => println("OK")
  }

  fooActor ! Foo 
  fooActor ! "Hello!" // doesn't compile -> Type mismatch; found: String("Hello!"); required: FooMessage;

}

W rzeczywistości ograniczenie aktora do posiadania tylko jednego typu jako wejścia nie jest zbyt użyteczne. Bardziej przydatne dla mnie jest wymienienie możliwych wejść w ściśle wpisany sposób.

Istnieje podejście do ściśle wpisanych wejść aktorów (SynapseGrid):

case class Contact[T](...)
case class Signal[T](contact:Contact[T], data:T)

W Twoim przypadku interfejs składa się z pojedynczego kontaktu wejściowego:

val FooInput = contact[FooMessage]("FooInput")

W ramach SynapseGrid obsługa sygnałów jest zdefiniowana za pomocą Builder:

class FooActorBuilder extends SystemBuilder {
  inputs(FooInput, OtherInput)
  FooInput.foreach(fooMessage => () //OK
  )
  OtherInput.foreach(...)
}

Oczywiście nie można skonstruować Sygnał z niekompatybilnymi typami. W ten sposób mamy sprawdzanie czasu kompilacji. W SynapseGrid znajduje się DSL do pracy z sygnałami i kontaktami. Na przykład, aby wysłać Foo lub Bar z zewnątrz:

val SomeOtherContact = contact[Boolean]("SomeOtherContact")
SomeOtherContact.map(flag => if(flag) Foo else Bar) >> FooInput

Oczywiście można po prostu wysłać wiadomość:

val inputMessage = Signal(FooInput, Foo)
actor ! inputMessage

Wygląda na to, że obsługa kanału Akka miała się tym zająć, ale (zgodnie z komentarz został już usunięty z Akka w wersji 2.3).

W dokumentacji Akka 2.2.3 znajduje się dobra sekcja "tło projektu", która omawia trudności w obsłudze wysyłanych wiadomości i odpowiedzi.

Jest też dobra rozmowa Nescala Rolanda Kuhna, Akka Typed Channels: Implementing Type Calculations as Makra ([YouTube] / [Slides] ), który omawia implementację typowanych kanałów.