Packages

object EventStream

Source
EventStream.scala
Linear Supertypes
Content Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventStream
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. sealed trait Command extends AnyRef

    The set of commands accepted by the akka.actor.typed.ActorSystem.eventStream.

    The set of commands accepted by the akka.actor.typed.ActorSystem.eventStream.

    Not for user Extension

    Annotations
    @DoNotInherit()
  2. final case class Publish[E](event: E) extends Command with Product with Serializable

    Publish an event of type E by sending this command to the akka.actor.typed.ActorSystem.eventStream.

  3. final case class Subscribe[E](subscriber: ActorRef[E])(implicit classTag: ClassTag[E]) extends Command with Product with Serializable

    Subscribe a typed actor to listen for types or subtypes of E by sending this command to the akka.actor.typed.ActorSystem.eventStream.

    Subscribe a typed actor to listen for types or subtypes of E by sending this command to the akka.actor.typed.ActorSystem.eventStream.

    Simple example

    sealed trait A
    case object A1 extends A
    //listen for all As
    def subscribe(actorSystem: ActorSystem[_], actorRef: ActorRef[A]) =
      actorSystem.eventStream ! EventStream.Subscribe(actorRef)
    //listen for A1s only
    def subscribe(actorSystem: ActorSystem[_], actorRef: ActorRef[A]) =
      actorSystem.eventStream ! EventStream.Subscribe[A1](actorRef)
  4. final case class Unsubscribe[E](subscriber: ActorRef[E]) extends Command with Product with Serializable

    Unsubscribe an actor ref from the event stream by sending this command to the akka.actor.typed.ActorSystem.eventStream.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped