Package akka.stream
Interface SubscriptionWithCancelException
-
- All Superinterfaces:
org.reactivestreams.Subscription
- All Known Implementing Classes:
StreamTestKit.PublisherProbeSubscription
public interface SubscriptionWithCancelException extends org.reactivestreams.Subscription
Extension 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 class
SubscriptionWithCancelException.NoMoreElementsNeeded$
static class
SubscriptionWithCancelException.NonFailureCancellation
Not for user extensionstatic class
SubscriptionWithCancelException.StageWasCompleted$
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cancel()
void
cancel(java.lang.Throwable cause)
-