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 and Description
static class	ReactiveStreamsCompliance.SignalThrewException
static interface	ReactiveStreamsCompliance.SpecViolation

Constructor Summary

Constructors

Constructor and Description
ReactiveStreamsCompliance()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveStreamsCompliance

public ReactiveStreamsCompliance()

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)