Class MyLambdaSubscriber<T>

  • All Implemented Interfaces:
    io.reactivex.disposables.Disposable, io.reactivex.FlowableSubscriber<T>, io.reactivex.observers.LambdaConsumerIntrospection, Serializable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

    public final class MyLambdaSubscriber<T>
    extends AtomicReference<org.reactivestreams.Subscription>
    implements io.reactivex.FlowableSubscriber<T>, org.reactivestreams.Subscription, io.reactivex.disposables.Disposable, io.reactivex.observers.LambdaConsumerIntrospection
    See Also:
    Serialized Form
    • Constructor Detail

      • MyLambdaSubscriber

        public MyLambdaSubscriber​(io.reactivex.functions.Consumer<? super T> onNext,
                                  io.reactivex.functions.Consumer<? super Throwable> onError,
                                  io.reactivex.functions.Action onComplete,
                                  long requestValue)
    • Method Detail

      • onSubscribe

        public void onSubscribe​(org.reactivestreams.Subscription s)
        Specified by:
        onSubscribe in interface io.reactivex.FlowableSubscriber<T>
        Specified by:
        onSubscribe in interface org.reactivestreams.Subscriber<T>
      • onNext

        public void onNext​(T t)
        Specified by:
        onNext in interface org.reactivestreams.Subscriber<T>
      • onError

        public void onError​(Throwable t)
        Specified by:
        onError in interface org.reactivestreams.Subscriber<T>
      • onComplete

        public void onComplete()
        Specified by:
        onComplete in interface org.reactivestreams.Subscriber<T>
      • dispose

        public void dispose()
        Specified by:
        dispose in interface io.reactivex.disposables.Disposable
      • isDisposed

        public boolean isDisposed()
        Specified by:
        isDisposed in interface io.reactivex.disposables.Disposable
      • request

        public void request​(long n)
        Specified by:
        request in interface org.reactivestreams.Subscription
      • cancel

        public void cancel()
        Specified by:
        cancel in interface org.reactivestreams.Subscription
      • hasCustomOnError

        public boolean hasCustomOnError()
        Specified by:
        hasCustomOnError in interface io.reactivex.observers.LambdaConsumerIntrospection