c

akka.grpc.internal

CancellationBarrierGraphStage

class CancellationBarrierGraphStage[T] extends GraphStage[FlowShape[T, T]]

'barrier' that makes sure that, even when downstream is cancelled, the complete upstream is consumed.

Source
CancellationBarrierGraphStage.scala
Linear Supertypes
GraphStage[FlowShape[T, T]], GraphStageWithMaterializedValue[FlowShape[T, T], NotUsed], Graph[FlowShape[T, T], NotUsed], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CancellationBarrierGraphStage
  2. GraphStage
  3. GraphStageWithMaterializedValue
  4. Graph
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new CancellationBarrierGraphStage()

Type Members

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

Value Members

  1. def addAttributes(attr: Attributes): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  2. def async(dispatcher: String, inputBufferSize: Int): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  3. def async(dispatcher: String): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  4. def async: Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  5. def createLogic(inheritedAttributes: Attributes): GraphStageLogic
    Definition Classes
    CancellationBarrierGraphStage → GraphStage
  6. final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
    Definition Classes
    GraphStage → GraphStageWithMaterializedValue
  7. def getAttributes: Attributes
    Definition Classes
    Graph
  8. val in: Inlet[T]
  9. def named(name: String): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    Graph
  10. val out: Outlet[T]
  11. val shape: FlowShape[T, T]
    Definition Classes
    CancellationBarrierGraphStage → Graph
  12. final def withAttributes(attr: Attributes): Graph[FlowShape[T, T], NotUsed]
    Definition Classes
    GraphStageWithMaterializedValue → Graph