public class ReactiveStreamsCompliance$
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static ReactiveStreamsCompliance$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
ReactiveStreamsCompliance$() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
CanNotSubscribeTheSameSubscriberMultipleTimes() |
java.lang.Throwable |
canNotSubscribeTheSameSubscriberMultipleTimesException() |
java.lang.Throwable |
elementMustNotBeNullException() |
java.lang.String |
ElementMustNotBeNullMsg() |
java.lang.Throwable |
exceptionMustNotBeNullException() |
java.lang.String |
ExceptionMustNotBeNullMsg() |
java.lang.Throwable |
numberOfElementsInRequestMustBePositiveException() |
java.lang.String |
NumberOfElementsInRequestMustBePositiveMsg() |
<T> void |
rejectAdditionalSubscriber(org.reactivestreams.Subscriber<T> subscriber,
java.lang.String rejector) |
<T> void |
rejectDueToNonPositiveDemand(org.reactivestreams.Subscriber<T> subscriber) |
<T> void |
rejectDuplicateSubscriber(org.reactivestreams.Subscriber<T> subscriber) |
<T> void |
requireNonNullElement(T element) |
void |
requireNonNullException(java.lang.Throwable cause) |
<T> void |
requireNonNullSubscriber(org.reactivestreams.Subscriber<T> subscriber) |
void |
requireNonNullSubscription(org.reactivestreams.Subscription subscription) |
java.lang.Throwable |
subscriberMustNotBeNullException() |
java.lang.String |
SubscriberMustNotBeNullMsg() |
java.lang.Throwable |
subscriptionMustNotBeNullException() |
java.lang.String |
SubscriptionMustNotBeNullMsg() |
java.lang.String |
SupportsOnlyASingleSubscriber() |
void |
tryCancel(org.reactivestreams.Subscription subscription) |
<T> void |
tryOnComplete(org.reactivestreams.Subscriber<T> subscriber) |
<T> void |
tryOnError(org.reactivestreams.Subscriber<T> subscriber,
java.lang.Throwable error) |
<T> void |
tryOnNext(org.reactivestreams.Subscriber<T> subscriber,
T element) |
<T> void |
tryOnSubscribe(org.reactivestreams.Subscriber<T> subscriber,
org.reactivestreams.Subscription subscription) |
void |
tryRequest(org.reactivestreams.Subscription subscription,
long demand) |
public static final ReactiveStreamsCompliance$ MODULE$
public final java.lang.String CanNotSubscribeTheSameSubscriberMultipleTimes()
public final java.lang.String SupportsOnlyASingleSubscriber()
public final java.lang.String NumberOfElementsInRequestMustBePositiveMsg()
public final java.lang.String SubscriberMustNotBeNullMsg()
public final java.lang.String ExceptionMustNotBeNullMsg()
public final java.lang.String ElementMustNotBeNullMsg()
public final java.lang.String SubscriptionMustNotBeNullMsg()
public final java.lang.Throwable numberOfElementsInRequestMustBePositiveException()
public final java.lang.Throwable canNotSubscribeTheSameSubscriberMultipleTimesException()
public final java.lang.Throwable subscriberMustNotBeNullException()
public final java.lang.Throwable exceptionMustNotBeNullException()
public final java.lang.Throwable elementMustNotBeNullException()
public final java.lang.Throwable subscriptionMustNotBeNullException()
public final <T> void rejectDuplicateSubscriber(org.reactivestreams.Subscriber<T> subscriber)
public final <T> void rejectAdditionalSubscriber(org.reactivestreams.Subscriber<T> subscriber, java.lang.String rejector)
public final <T> void rejectDueToNonPositiveDemand(org.reactivestreams.Subscriber<T> subscriber)
public final <T> void requireNonNullSubscriber(org.reactivestreams.Subscriber<T> subscriber)
public final void requireNonNullException(java.lang.Throwable cause)
public final <T> void requireNonNullElement(T element)
public final void requireNonNullSubscription(org.reactivestreams.Subscription subscription)
public final <T> void tryOnError(org.reactivestreams.Subscriber<T> subscriber, java.lang.Throwable error)
public final <T> void tryOnNext(org.reactivestreams.Subscriber<T> subscriber, T element)
public final <T> void tryOnSubscribe(org.reactivestreams.Subscriber<T> subscriber, org.reactivestreams.Subscription subscription)
public final <T> void tryOnComplete(org.reactivestreams.Subscriber<T> subscriber)
public final void tryRequest(org.reactivestreams.Subscription subscription, long demand)
public final void tryCancel(org.reactivestreams.Subscription subscription)