public static final class StreamUtils.DelayCancellationStage<T>
extends akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage<T>
Constructor and Description |
---|
DelayCancellationStage(scala.concurrent.duration.Duration cancelAfter) |
Modifier and Type | Method and Description |
---|---|
akka.stream.stage.GraphStageLogic |
createLogic(akka.stream.Attributes inheritedAttributes) |
in, out, shape
addAttributes, async, initialAttributes, module, named, withAttributes