public class ReactiveStreamsCompliance
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
ReactiveStreamsCompliance.SignalThrewException |
static interface |
ReactiveStreamsCompliance.SpecViolation |
Constructor and Description |
---|
ReactiveStreamsCompliance() |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
CanNotSubscribeTheSameSubscriberMultipleTimes() |
static java.lang.Throwable |
canNotSubscribeTheSameSubscriberMultipleTimesException() |
static java.lang.Throwable |
elementMustNotBeNullException() |
static java.lang.String |
ElementMustNotBeNullMsg() |
static java.lang.Throwable |
exceptionMustNotBeNullException() |
static java.lang.String |
ExceptionMustNotBeNullMsg() |
static java.lang.Throwable |
numberOfElementsInRequestMustBePositiveException() |
static java.lang.String |
NumberOfElementsInRequestMustBePositiveMsg() |
static <T> void |
rejectAdditionalSubscriber(org.reactivestreams.Subscriber<T> subscriber,
java.lang.String rejector) |
static <T> void |
rejectDueToNonPositiveDemand(org.reactivestreams.Subscriber<T> subscriber) |
static <T> void |
rejectDuplicateSubscriber(org.reactivestreams.Subscriber<T> subscriber) |
static <T> void |
requireNonNullElement(T element) |
static void |
requireNonNullException(java.lang.Throwable cause) |
static <T> void |
requireNonNullSubscriber(org.reactivestreams.Subscriber<T> subscriber) |
static void |
requireNonNullSubscription(org.reactivestreams.Subscription subscription) |
static java.lang.Throwable |
subscriberMustNotBeNullException() |
static java.lang.String |
SubscriberMustNotBeNullMsg() |
static java.lang.Throwable |
subscriptionMustNotBeNullException() |
static java.lang.String |
SubscriptionMustNotBeNullMsg() |
static java.lang.String |
SupportsOnlyASingleSubscriber() |
static void |
tryCancel(org.reactivestreams.Subscription subscription) |
static <T> void |
tryOnComplete(org.reactivestreams.Subscriber<T> subscriber) |
static <T> void |
tryOnError(org.reactivestreams.Subscriber<T> subscriber,
java.lang.Throwable error) |
static <T> void |
tryOnNext(org.reactivestreams.Subscriber<T> subscriber,
T element) |
static <T> void |
tryOnSubscribe(org.reactivestreams.Subscriber<T> subscriber,
org.reactivestreams.Subscription subscription) |
static void |
tryRequest(org.reactivestreams.Subscription subscription,
long demand) |
public static final java.lang.String CanNotSubscribeTheSameSubscriberMultipleTimes()
public static final java.lang.String SupportsOnlyASingleSubscriber()
public static final java.lang.String NumberOfElementsInRequestMustBePositiveMsg()
public static final java.lang.String SubscriberMustNotBeNullMsg()
public static final java.lang.String ExceptionMustNotBeNullMsg()
public static final java.lang.String ElementMustNotBeNullMsg()
public static final java.lang.String SubscriptionMustNotBeNullMsg()
public static final java.lang.Throwable numberOfElementsInRequestMustBePositiveException()
public static final java.lang.Throwable canNotSubscribeTheSameSubscriberMultipleTimesException()
public static final java.lang.Throwable subscriberMustNotBeNullException()
public static final java.lang.Throwable exceptionMustNotBeNullException()
public static final java.lang.Throwable elementMustNotBeNullException()
public static final java.lang.Throwable subscriptionMustNotBeNullException()
public static final <T> void rejectDuplicateSubscriber(org.reactivestreams.Subscriber<T> subscriber)
public static final <T> void rejectAdditionalSubscriber(org.reactivestreams.Subscriber<T> subscriber, java.lang.String rejector)
public static final <T> void rejectDueToNonPositiveDemand(org.reactivestreams.Subscriber<T> subscriber)
public static final <T> void requireNonNullSubscriber(org.reactivestreams.Subscriber<T> subscriber)
public static final void requireNonNullException(java.lang.Throwable cause)
public static final <T> void requireNonNullElement(T element)
public static final void requireNonNullSubscription(org.reactivestreams.Subscription subscription)
public static final <T> void tryOnError(org.reactivestreams.Subscriber<T> subscriber, java.lang.Throwable error)
public static final <T> void tryOnNext(org.reactivestreams.Subscriber<T> subscriber, T element)
public static final <T> void tryOnSubscribe(org.reactivestreams.Subscriber<T> subscriber, org.reactivestreams.Subscription subscription)
public static final <T> void tryOnComplete(org.reactivestreams.Subscriber<T> subscriber)
public static final void tryRequest(org.reactivestreams.Subscription subscription, long demand)
public static final void tryCancel(org.reactivestreams.Subscription subscription)