86ded1fb0b
- some API docs - require names for top-level actors - allow names for children - flag error when no channels declared
26 lines
849 B
Scala
26 lines
849 B
Scala
/**
|
|
* Copyright (C) 2009-2013 Typesafe Inc. <http://www.typesafe.com>
|
|
*/
|
|
|
|
package akka.channels
|
|
|
|
import akka.actor.ExtensionKey
|
|
import akka.actor.Extension
|
|
import akka.actor.ExtendedActorSystem
|
|
import scala.reflect.runtime.universe._
|
|
import akka.actor.Props
|
|
import scala.reflect.ClassTag
|
|
import scala.reflect.runtime.universe
|
|
import akka.actor.Actor
|
|
|
|
object ChannelExt extends ExtensionKey[ChannelExtension]
|
|
|
|
class ChannelExtension(system: ExtendedActorSystem) extends Extension {
|
|
|
|
// FIXME: kick-start the universe (needed due to thread safety issues in runtime mirror)
|
|
// see https://issues.scala-lang.org/browse/SI-6240
|
|
private val t = typeTag[(Int, Int) :+: TNil]
|
|
|
|
def actorOf[Ch <: ChannelList](factory: ⇒ Actor with Channels[TNil, Ch], name: String): ChannelRef[Ch] =
|
|
new ChannelRef[Ch](system.actorOf(Props(factory), name))
|
|
}
|