Type Members

1.  final case class ActiveSourceTerminated[Name](name: Name, cause: Option[Throwable]) extends ControlOutput[Name, Nothing, Nothing, Nothing] with Product with Serializable

   Signals that the source has terminated with the given cause.

   Signals that the source has terminated with the given cause. Downstream is responsible for reacting to the termination signal and changing the configuration if necessary.

2.  sealed trait ControlOutput[Name, +ConfigAndMat, +A, +Offset] extends Output[Name, ConfigAndMat, A, Offset]
3.  final case class DeadlockDetected[Name, +A](elems: Seq[(Name, A)], trigger: DeadlockTrigger) extends ControlOutput[Name, Nothing, A, Nothing] with Product with Serializable

   Signals that the received elements from active sources have spread out over so many buckets that the remaining active sources with outstanding elements cannot reach the configured threshold.

   Signals that the received elements from active sources have spread out over so many buckets that the remaining active sources with outstanding elements cannot reach the configured threshold. Reconfiguration is necessary to make progress.

4.  sealed trait DeadlockTrigger extends Product with Serializable

   Classifies the event that caused the deadlock to appear

5.  final case class NewConfiguration[Name, +ConfigAndMat, +Offset](newConfig: OrderedBucketMergeConfig[Name, ConfigAndMat], startingOffset: Offset) extends ControlOutput[Name, ConfigAndMat, Nothing, Offset] with Product with Serializable

   Signals the new configuration that is active for all subsequent elements until the next NewConfiguration and the materialized values for the newly created sources.

   Signals the new configuration that is active for all subsequent elements until the next NewConfiguration and the materialized values for the newly created sources.

   startingOffset

   The exclusive offset where the subscription starts

6.  sealed trait Output[Name, +ConfigAndMat, +A, +Offset] extends Product with Serializable

   Outputs of the OrderedBucketMergeHub, combines actual data with control messages

7.  final case class OutputElement[Name, +A](elem: NonEmpty[Map[Name, A]]) extends Output[Name, Nothing, A, Nothing] with Product with Serializable

   Actual data output