Package akka.stream
Interface SubscriptionWithCancelException
-
- All Superinterfaces:
org.reactivestreams.Subscription
- All Known Implementing Classes:
StreamTestKit.PublisherProbeSubscription
public interface SubscriptionWithCancelException extends org.reactivestreams.SubscriptionExtension of Subscription that allows to pass a cause when a subscription is cancelled.Subscribers can check for this trait and use its
cancel(cause)method instead of the regular cancel method to pass a cancellation cause.Not for user extension.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classSubscriptionWithCancelException.NoMoreElementsNeeded$static classSubscriptionWithCancelException.NonFailureCancellationNot for user extensionstatic classSubscriptionWithCancelException.StageWasCompleted$
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcancel()voidcancel(java.lang.Throwable cause)
-