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