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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final ReactiveStreamsCompliance$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ReactiveStreamsCompliance$

public ReactiveStreamsCompliance$()

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)