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.

    • Method Detail

      • cancel

        void cancel()
        Specified by:
        cancel in interface org.reactivestreams.Subscription
      • cancel

        void cancel​(java.lang.Throwable cause)