com.digitalasset.canton.platform.pekkostreams.dispatcher
SignalDispatcher
Companion object SignalDispatcher
class SignalDispatcher extends AnyRef
A fanout signaller that can be subscribed to dynamically. Signals may be coalesced, but if a signal is sent, we guarantee that all consumers subscribed before the signal is sent will eventually receive a signal.
- Alphabetic
- By Inheritance
- SignalDispatcher
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- def fail(throwableBuilder: () => Throwable): Future[Unit]
Closes this SignalDispatcher by failing the existing Source subscriptions with the provided throwable.
- 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
- val logger: Logger
- 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()
- def shutdown(): Future[Unit]
Closes this SignalDispatcher by gracefully completing the existing Source subscriptions.
Closes this SignalDispatcher by gracefully completing the existing Source subscriptions. For any downstream with pending signals, at least one such signal will be sent first.
- def signal(): Unit
Signal to this Dispatcher that there's a new head
Index.Signal to this Dispatcher that there's a new head
Index. The Dispatcher will emit values on all streams until the new head is reached. - def subscribe(signalOnSubscribe: Boolean = false): Source[Signal, NotUsed]
Returns a Source that, when materialized, subscribes to this SignalDispatcher.
Returns a Source that, when materialized, subscribes to this SignalDispatcher.
- signalOnSubscribe
True if you want to send a signal to the new subscription.
- 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])