Class SubstreamCancelStrategy

java.lang.Object
org.apache.pekko.stream.SubstreamCancelStrategy
Direct Known Subclasses:
SubstreamCancelStrategies.Drain$, SubstreamCancelStrategies.Propagate$

public abstract class SubstreamCancelStrategy extends Object
Deprecated.
Use .withAttributes(ActorAttributes.supervisionStrategy(equivalentDecider)) rather than a SubstreamCancelStrategy. Since 1.1.0.
Represents a strategy that decides how to deal with substream events.
  • Constructor Details

    • SubstreamCancelStrategy

      public SubstreamCancelStrategy()
      Deprecated.
  • Method Details

    • propagate

      public static SubstreamCancelStrategy propagate()
      Deprecated.
      Cancel the stream of streams if any substream is cancelled.
    • drain

      public static SubstreamCancelStrategy drain()
      Deprecated.
      Drain substream on cancellation in order to prevent stalling of the stream of streams.