public static final class StreamUtils.DelayCancellationStage<T>
extends org.apache.pekko.stream.impl.fusing.GraphStages.SimpleLinearGraphStage<T>
| Constructor and Description |
|---|
DelayCancellationStage(scala.concurrent.duration.Duration cancelAfter) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.pekko.stream.stage.GraphStageLogic |
createLogic(org.apache.pekko.stream.Attributes inheritedAttributes) |
in, out, shapecreateLogicAndMaterializedValueaddAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes