akka.stream

Class SubstreamCancelStrategy$

java.lang.Object

akka.stream.SubstreamCancelStrategy$

public class SubstreamCancelStrategy$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static SubstreamCancelStrategy$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
SubstreamCancelStrategy$()

Method Summary

Modifier and Type	Method and Description
SubstreamCancelStrategy	drain() Drain substream on cancellation in order to prevent stalling of the stream of streams.
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

Field Detail

MODULE$

public static final SubstreamCancelStrategy$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

SubstreamCancelStrategy$

public SubstreamCancelStrategy$()

Method Detail

propagate

public SubstreamCancelStrategy propagate()

Cancel the stream of streams if any substream is cancelled.

Returns:

(undocumented)

drain

public SubstreamCancelStrategy drain()

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

Returns:

(undocumented)