trait EventStream extends AnyRef
An EventStream allows local actors to register for certain message types, including their subtypes automatically. Publishing events will broadcast them to all currently subscribed actors with matching subscriptions for the event type.
IMPORTANT NOTICE
This EventStream is local to the ActorSystem, it does not span a cluster. For disseminating messages across a cluster please refer to the DistributedPubSub module.
- Source
- EventStream.scala
- Alphabetic
- By Inheritance
- EventStream
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
logLevel: LogLevel
Query the current minimum log level.
-
abstract
def
publish[T](event: T): Unit
Publishes the specified Event to this bus
-
abstract
def
setLogLevel(loglevel: LogLevel): Unit
Change the current minimum log level.
-
abstract
def
subscribe[T](subscriber: ActorRef[T], to: Class[T]): Boolean
Attempts to register the subscriber to the specified Classifier
Attempts to register the subscriber to the specified Classifier
- returns
true if successful and false if not (because it was already subscribed to that Classifier, or otherwise)
-
abstract
def
unsubscribe[T](subscriber: ActorRef[T]): Unit
Attempts to deregister the subscriber from all Classifiers it may be subscribed to
-
abstract
def
unsubscribe[T](subscriber: ActorRef[T], from: Class[T]): Boolean
Attempts to deregister the subscriber from the specified Classifier
Attempts to deregister the subscriber from the specified Classifier
- returns
true if successful and false if not (because it wasn't subscribed to that Classifier, or otherwise)
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from EventStream to any2stringadd[EventStream] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (EventStream, B)
- Implicit
- This member is added by an implicit conversion from EventStream to ArrowAssoc[EventStream] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
ensuring(cond: (EventStream) ⇒ Boolean, msg: ⇒ Any): EventStream
- Implicit
- This member is added by an implicit conversion from EventStream to Ensuring[EventStream] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (EventStream) ⇒ Boolean): EventStream
- Implicit
- This member is added by an implicit conversion from EventStream to Ensuring[EventStream] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): EventStream
- Implicit
- This member is added by an implicit conversion from EventStream to Ensuring[EventStream] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): EventStream
- Implicit
- This member is added by an implicit conversion from EventStream to Ensuring[EventStream] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from EventStream to StringFormat[EventStream] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
→[B](y: B): (EventStream, B)
- Implicit
- This member is added by an implicit conversion from EventStream to ArrowAssoc[EventStream] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc