Package org.apache.pekko.stream

Class Attributes.NestedMaterializationCancellationPolicy$

java.lang.Object

org.apache.pekko.stream.Attributes.NestedMaterializationCancellationPolicy$

Enclosing class:

Attributes

public static class Attributes.NestedMaterializationCancellationPolicy$
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
NestedMaterializationCancellationPolicy$()

Method Summary

Modifier and Type	Method	Description
Attributes.NestedMaterializationCancellationPolicy	Default()	Default Attributes.NestedMaterializationCancellationPolicy, please see {@link pekko.stream.Attributes.NestedMaterializationCancellationPolicy.EagerCancellation()} for details.
Attributes.NestedMaterializationCancellationPolicy	EagerCancellation()	A Attributes.NestedMaterializationCancellationPolicy that configures graph stages delaying nested flow materialization to cancel immediately when downstream cancels before nested flow materialization.
Attributes.NestedMaterializationCancellationPolicy	PropagateToNested()	A Attributes.NestedMaterializationCancellationPolicy that configures graph stages delaying nested flow materialization to delay cancellation when downstream cancels before nested flow materialization.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Attributes.NestedMaterializationCancellationPolicy$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

NestedMaterializationCancellationPolicy$

public NestedMaterializationCancellationPolicy$()

Method Detail

EagerCancellation

public Attributes.NestedMaterializationCancellationPolicy EagerCancellation()

A Attributes.NestedMaterializationCancellationPolicy that configures graph stages delaying nested flow materialization to cancel immediately when downstream cancels before nested flow materialization. This applies to pekko.stream.scaladsl.FlowOps.flatMapPrefix, pekko.stream.scaladsl.Flow.futureFlow and derived operators.

PropagateToNested

public Attributes.NestedMaterializationCancellationPolicy PropagateToNested()

A Attributes.NestedMaterializationCancellationPolicy that configures graph stages delaying nested flow materialization to delay cancellation when downstream cancels before nested flow materialization. Once the nested flow is materialized it will be cancelled immediately. This applies to pekko.stream.scaladsl.FlowOps.flatMapPrefix, pekko.stream.scaladsl.Flow.futureFlow and derived operators.

Default

public Attributes.NestedMaterializationCancellationPolicy Default()

Default Attributes.NestedMaterializationCancellationPolicy, please see {@link pekko.stream.Attributes.NestedMaterializationCancellationPolicy.EagerCancellation()} for details.