Class ReactiveStreamsCompliance


  • public class ReactiveStreamsCompliance
    extends java.lang.Object
    INTERNAL API
    • 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)