c

akka.stream.contrib

KeepAliveConcat

final case class KeepAliveConcat[T](keepAliveFailoverSize: Int, interval: FiniteDuration, extrapolate: (T) ⇒ Seq[T]) extends GraphStage[FlowShape[T, T]] with Product with Serializable

Sends elements from buffer if upstream does not emit for a configured amount of time. In other words, this stage attempts to maintains a base rate of emitted elements towards the downstream using elements from upstream.

If upstream emits new elements until the accumulated elements in the buffer exceed the specified minimum size used as the keep alive elements, then the base rate is no longer maintained until we reach another period without elements form upstream.

The keep alive period is the keep alive failover size times the interval.

Emits when upstream emits an element or if the upstream was idle for the configured period

Backpressures when downstream backpressures

Completes when upstream completes

Cancels when downstream cancels

See also

akka.stream.scaladsl.FlowOps#keepAlive

akka.stream.scaladsl.FlowOps#expand

Linear Supertypes
Serializable, Serializable, Product, Equals, GraphStage[FlowShape[T, T]], GraphStageWithMaterializedValue[FlowShape[T, T], NotUsed], Graph[FlowShape[T, T], NotUsed], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KeepAliveConcat
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. GraphStage
  7. GraphStageWithMaterializedValue
  8. Graph
  9. AnyRef
  10. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new KeepAliveConcat(keepAliveFailoverSize: Int, interval: FiniteDuration, extrapolate: (T) ⇒ Seq[T])

Type Members

  1. type Shape = FlowShape[T, T]
    Definition Classes
    Graph

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def addAttributes(attr: Attributes): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def async(dispatcher: String, inputBufferSize: Int): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  7. def async(dispatcher: String): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  8. def async: Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  9. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  10. def createLogic(inheritedAttributes: Attributes): GraphStageLogic
    Definition Classes
    KeepAliveConcat → GraphStage
  11. final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
    Definition Classes
    GraphStage → GraphStageWithMaterializedValue
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. val extrapolate: (T) ⇒ Seq[T]
  14. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. val in: Inlet[T]
  17. def initialAttributes: Attributes
    Attributes
    protected
    Definition Classes
    GraphStageWithMaterializedValue
  18. val interval: FiniteDuration
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. val keepAliveFailoverSize: Int
  21. def named(name: String): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  22. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  23. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  25. val out: Outlet[T]
  26. val shape: FlowShape[T, T]
    Definition Classes
    KeepAliveConcat → Graph
  27. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  28. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  31. final def withAttributes(attr: Attributes): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    GraphStageWithMaterializedValue → Graph

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from GraphStage[FlowShape[T, T]]

Inherited from GraphStageWithMaterializedValue[FlowShape[T, T], NotUsed]

Inherited from Graph[FlowShape[T, T], NotUsed]

Inherited from AnyRef

Inherited from Any

Ungrouped