io.servicetalk.concurrent.internal

Class DuplicateSubscribeException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

io.servicetalk.concurrent.internal.RejectedSubscribeException

io.servicetalk.concurrent.internal.DuplicateSubscribeException

All Implemented Interfaces:

RejectedSubscribeError, java.io.Serializable

public final class DuplicateSubscribeException
extends RejectedSubscribeException

Used in scenarios where a subscribe to an asynchronous source is subscribed to, but there is already a subscriber and the source doesn't support multiple subscribers.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DuplicateSubscribeException(java.lang.Object existingSubscriber, java.lang.Object attemptedSubscriber) Create a new instance.
DuplicateSubscribeException(java.lang.Object existingSubscriber, java.lang.Object attemptedSubscriber, java.lang.String message) Create a new instance.

Method Summary

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

DuplicateSubscribeException

public DuplicateSubscribeException(@Nullable
                                   java.lang.Object existingSubscriber,
                                   java.lang.Object attemptedSubscriber)

Create a new instance.

Parameters:

existingSubscriber - The existing subscriber, or state that prevented the subscribe from completing.

attemptedSubscriber - The subscriber which failed to subscribe.

DuplicateSubscribeException

public DuplicateSubscribeException(@Nullable
                                   java.lang.Object existingSubscriber,
                                   java.lang.Object attemptedSubscriber,
                                   java.lang.String message)

Create a new instance.

Parameters:

existingSubscriber - The existing subscriber, or state that prevented the subscribe from completing.

attemptedSubscriber - The subscriber which failed to subscribe.

message - An optional message clarifying the situation.