Type Members

1.  trait Dispatcher[Index] extends AnyRef

   A fanout signaller, representing a stream of external updates, that can be subscribed to dynamically at a given point in the stream.

   A fanout signaller, representing a stream of external updates, that can be subscribed to dynamically at a given point in the stream. Stream positions are given by the Index type, and stream values are given by T. Subscribing to a point yields all values starting at that point. It is assumed that the head index is the "end of the stream" and has no value.

   Implementations must be thread-safe, so must the callbacks provided to it.

2.  final class DispatcherImpl[Index] extends Dispatcher[Index]
3.  class SignalDispatcher extends AnyRef

   A fanout signaller that can be subscribed to dynamically.

   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.

4.  sealed abstract class SubSource[Index, T] extends (Index, Index) => Source[(Index, T), NotUsed]

   Defines how the progress on the ledger should be mapped to look-up operations