Package akka.stream
Class SubstreamCancelStrategy
- java.lang.Object
-
- akka.stream.SubstreamCancelStrategy
-
- Direct Known Subclasses:
SubstreamCancelStrategies.Drain$
,SubstreamCancelStrategies.Propagate$
public abstract class SubstreamCancelStrategy extends java.lang.Object
Represents a strategy that decides how to deal with substream events.
-
-
Constructor Summary
Constructors Constructor Description SubstreamCancelStrategy()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static SubstreamCancelStrategy
drain()
Drain substream on cancellation in order to prevent stalling of the stream of streams.static SubstreamCancelStrategy
propagate()
Cancel the stream of streams if any substream is cancelled.
-
-
-
Method Detail
-
propagate
public static SubstreamCancelStrategy propagate()
Cancel the stream of streams if any substream is cancelled.
-
drain
public static SubstreamCancelStrategy drain()
Drain substream on cancellation in order to prevent stalling of the stream of streams.
-
-