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 and Description
SubstreamCancelStrategy()

Method Summary

Modifier and Type	Method and 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubstreamCancelStrategy

public SubstreamCancelStrategy()

Method Detail

propagate

public static SubstreamCancelStrategy propagate()

Cancel the stream of streams if any substream is cancelled.

Returns:

(undocumented)

drain

public static SubstreamCancelStrategy drain()

Drain substream on cancellation in order to prevent stalling of the stream of streams.

Returns:

(undocumented)