Package org.apache.pekko.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 extension
static class	SubscriptionWithCancelException.StageWasCompleted$

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	cancel(Throwable cause)

Methods inherited from interface org.reactivestreams.Subscription

request

Method Details

cancel

void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

cancel

void cancel(Throwable cause)