object PubSub
- Alphabetic
- By Inheritance
- PubSub
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- case class Publish[T](data: T) extends PublisherMessage[T] with Product with Serializable
Represents a publish action
Represents a publish action
- T
represents the type of data that is published
- data
of type T that gets published
- sealed trait PublisherMessage[T] extends PubSub[T]
Represents the messages about publishing data e.g Publish
Represents the messages about publishing data e.g Publish
- T
represents the type of data that is published
- case class Subscribe[T](ref: ActorRef[T]) extends SubscriberMessage[T] with Product with Serializable
Represents the subscribe action where all the current state publishing from the particular component can be subscribed to
Represents the subscribe action where all the current state publishing from the particular component can be subscribed to
- T
represents the type of data that is subscribed
- ref
the reference of subscriber used to notify to when some data is published
- case class SubscribeOnly[T](ref: ActorRef[T], names: Set[StateName]) extends SubscriberMessage[T] with Product with Serializable
Represents the subscribe action for current states specified by a set of stateNames
Represents the subscribe action for current states specified by a set of stateNames
- T
represents the type of data that is subscribed
- ref
the reference of subscriber used to notify to when some data is published
- names
set of stateNames uniquely representating current states for a component
- sealed trait SubscriberMessage[T] extends PubSub[T]
Represents the messages about subscribing data e.g Subscribe and Unsubscribe
Represents the messages about subscribing data e.g Subscribe and Unsubscribe
- T
represents the type of data that is subscribed
- case class Unsubscribe[T](ref: ActorRef[T]) extends SubscriberMessage[T] with Product with Serializable
Represents a unsubscribe action
Represents a unsubscribe action
- T
represents the type of data that is subscribed
- ref
the reference of subscriber that no longer wishes to receive notification for published data
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])