Class ReactiveStreamsCompliance$


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