Package akka.http.impl.util
Class StreamUtils.DelayCancellationStage<T>
java.lang.Object
akka.stream.stage.GraphStageWithMaterializedValue<S,akka.NotUsed>
akka.stream.stage.GraphStage<akka.stream.FlowShape<T,T>>
akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage<T>
akka.http.impl.util.StreamUtils.DelayCancellationStage<T>
- All Implemented Interfaces:
akka.stream.Graph<akka.stream.FlowShape<T,
T>, akka.NotUsed>
- Enclosing class:
- StreamUtils
public static final class StreamUtils.DelayCancellationStage<T>
extends akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage<T>
INTERNAL API
-
Nested Class Summary
Nested classes/interfaces inherited from interface akka.stream.Graph
akka.stream.Graph.GraphMapMatVal<S extends akka.stream.Shape,
M extends Object> -
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionakka.stream.stage.GraphStageLogic
createLogic
(akka.stream.Attributes inheritedAttributes) Methods inherited from class akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage
in, out, shape
Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes
-
Constructor Details
-
DelayCancellationStage
public DelayCancellationStage(scala.concurrent.duration.Duration cancelAfter)
-
-
Method Details