com.digitalasset.canton.platform.pekkostreams.dispatcher
DispatcherImpl
Companion object DispatcherImpl
final class DispatcherImpl[Index] extends Dispatcher[Index]
- Alphabetic
- By Inheritance
- DispatcherImpl
- Dispatcher
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
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 cancel(throwableBuilder: () => Throwable): Future[Unit]
Triggers shutdown of the Dispatcher by eagerly failing all outstanding stream subscriptions with a throwable.
Triggers shutdown of the Dispatcher by eagerly failing all outstanding stream subscriptions with a throwable.
- throwableBuilder
Create a new throwable. It is important to create a new throwable for each failed subscription since the throwable closing the streams or parts of it can be mutable. (e.g. the io.grpc.Metadata provided as part of io.grpc.StatusRuntimeException is mutated in the gRPC layer)
- Definition Classes
- DispatcherImpl → Dispatcher
- 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 getHead(): Index
returns the head index where this Dispatcher is at
returns the head index where this Dispatcher is at
- Definition Classes
- DispatcherImpl → Dispatcher
- 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()
- def shutdown(): Future[Unit]
Triggers shutdown of the Dispatcher by completing all outstanding stream subscriptions.
Triggers shutdown of the Dispatcher by completing all outstanding stream subscriptions. This method ensures that all outstanding subscriptions have been notified with the latest signalled head and waits for their graceful completion.
- Definition Classes
- DispatcherImpl → Dispatcher
- def signalNewHead(head: Index): 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.- Definition Classes
- DispatcherImpl → Dispatcher
- def startingAt[T](startExclusive: Index, subsource: SubSource[Index, T], endInclusive: Option[Index] = None): Source[(Index, T), NotUsed]
Returns a stream of elements with the next index from start (exclusive) to end (inclusive) Throws
DispatcherIsClosedExceptionif dispatcher is in the shutting down stateReturns a stream of elements with the next index from start (exclusive) to end (inclusive) Throws
DispatcherIsClosedExceptionif dispatcher is in the shutting down state- Definition Classes
- DispatcherImpl → Dispatcher
- 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])