Type Members

1.  final case class ActiveSourceTerminated[Name](name: Name, cause: Option[Throwable]) extends ControlOutput[Name, 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, +Offset] extends Output[Name, ConfigAndMat, Nothing, Offset]
3.  final case class NewConfiguration[Name, +ConfigAndMat, +Offset](newConfig: OrderedBucketMergeConfig[Name, ConfigAndMat], startingOffset: Offset) extends ControlOutput[Name, ConfigAndMat, 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.

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

   Outputs of the OrderedBucketMergeHub, combines actual data with control messages

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

   Actual data output