Package akka.stream.impl
Class ReactiveStreamsCompliance
- java.lang.Object
-
- akka.stream.impl.ReactiveStreamsCompliance
-
public class ReactiveStreamsCompliance extends java.lang.Object
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ReactiveStreamsCompliance.SignalThrewException
static interface
ReactiveStreamsCompliance.SpecViolation
-
Constructor Summary
Constructors Constructor Description ReactiveStreamsCompliance()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Method Detail
-
CanNotSubscribeTheSameSubscriberMultipleTimes
public static final java.lang.String CanNotSubscribeTheSameSubscriberMultipleTimes()
-
SupportsOnlyASingleSubscriber
public static final java.lang.String SupportsOnlyASingleSubscriber()
-
NumberOfElementsInRequestMustBePositiveMsg
public static final java.lang.String NumberOfElementsInRequestMustBePositiveMsg()
-
SubscriberMustNotBeNullMsg
public static final java.lang.String SubscriberMustNotBeNullMsg()
-
ExceptionMustNotBeNullMsg
public static final java.lang.String ExceptionMustNotBeNullMsg()
-
ElementMustNotBeNullMsg
public static final java.lang.String ElementMustNotBeNullMsg()
-
SubscriptionMustNotBeNullMsg
public static final java.lang.String SubscriptionMustNotBeNullMsg()
-
numberOfElementsInRequestMustBePositiveException
public static final java.lang.Throwable numberOfElementsInRequestMustBePositiveException()
-
canNotSubscribeTheSameSubscriberMultipleTimesException
public static final java.lang.Throwable canNotSubscribeTheSameSubscriberMultipleTimesException()
-
subscriberMustNotBeNullException
public static final java.lang.Throwable subscriberMustNotBeNullException()
-
exceptionMustNotBeNullException
public static final java.lang.Throwable exceptionMustNotBeNullException()
-
elementMustNotBeNullException
public static final java.lang.Throwable elementMustNotBeNullException()
-
subscriptionMustNotBeNullException
public static final java.lang.Throwable subscriptionMustNotBeNullException()
-
rejectDuplicateSubscriber
public static final <T> void rejectDuplicateSubscriber(org.reactivestreams.Subscriber<T> subscriber)
-
rejectAdditionalSubscriber
public static final <T> void rejectAdditionalSubscriber(org.reactivestreams.Subscriber<T> subscriber, java.lang.String rejector)
-
rejectDueToNonPositiveDemand
public static final <T> void rejectDueToNonPositiveDemand(org.reactivestreams.Subscriber<T> subscriber)
-
requireNonNullSubscriber
public static final <T> void requireNonNullSubscriber(org.reactivestreams.Subscriber<T> subscriber)
-
requireNonNullException
public static final void requireNonNullException(java.lang.Throwable cause)
-
requireNonNullElement
public static final <T> void requireNonNullElement(T element)
-
requireNonNullSubscription
public static final void requireNonNullSubscription(org.reactivestreams.Subscription subscription)
-
tryOnError
public static final <T> void tryOnError(org.reactivestreams.Subscriber<T> subscriber, java.lang.Throwable error)
-
tryOnNext
public static final <T> void tryOnNext(org.reactivestreams.Subscriber<T> subscriber, T element)
-
tryOnSubscribe
public static final <T> void tryOnSubscribe(org.reactivestreams.Subscriber<T> subscriber, org.reactivestreams.Subscription subscription)
-
tryOnComplete
public static final <T> void tryOnComplete(org.reactivestreams.Subscriber<T> subscriber)
-
tryRequest
public static final void tryRequest(org.reactivestreams.Subscription subscription, long demand)
-
tryCancel
public static final void tryCancel(org.reactivestreams.Subscription subscription)
-
-