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