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) 
 -