Class MaybeFlatMapPublisher.FlatMapPublisherSubscriber<T,R>

java.lang.Object
java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription>
io.reactivex.rxjava3.internal.operators.mixed.MaybeFlatMapPublisher.FlatMapPublisherSubscriber<T,R>
All Implemented Interfaces:
FlowableSubscriber<R>, MaybeObserver<T>, Serializable, org.reactivestreams.Subscriber<R>, org.reactivestreams.Subscription
Enclosing class:
MaybeFlatMapPublisher<T,R>

static final class MaybeFlatMapPublisher.FlatMapPublisherSubscriber<T,R> extends AtomicReference<org.reactivestreams.Subscription> implements FlowableSubscriber<R>, MaybeObserver<T>, org.reactivestreams.Subscription
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • downstream

      final org.reactivestreams.Subscriber<? super R> downstream
    • mapper

      final Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper
    • upstream

      Disposable upstream
    • requested

      final AtomicLong requested
  • Constructor Details

    • FlatMapPublisherSubscriber

      FlatMapPublisherSubscriber(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
  • Method Details

    • onNext

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

      public void onError(Throwable t)
      Description copied from interface: MaybeObserver
      Notifies the MaybeObserver that the Maybe has experienced an error condition.

      If the Maybe calls this method, it will not thereafter call MaybeObserver.onSuccess(T).

      Specified by:
      onError in interface MaybeObserver<T>
      Specified by:
      onError in interface org.reactivestreams.Subscriber<T>
      Parameters:
      t - the exception encountered by the Maybe
    • onComplete

      public void onComplete()
      Description copied from interface: MaybeObserver
      Called once the deferred computation completes normally.
      Specified by:
      onComplete in interface MaybeObserver<T>
      Specified by:
      onComplete in interface org.reactivestreams.Subscriber<T>
    • 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
    • onSubscribe

      public void onSubscribe(Disposable d)
      Description copied from interface: MaybeObserver
      Provides the MaybeObserver with the means of cancelling (disposing) the connection (channel) with the Maybe in both synchronous (from within onSubscribe(Disposable) itself) and asynchronous manner.
      Specified by:
      onSubscribe in interface MaybeObserver<T>
      Parameters:
      d - the Disposable instance whose Disposable.dispose() can be called anytime to cancel the connection
    • onSuccess

      public void onSuccess(T t)
      Description copied from interface: MaybeObserver
      Notifies the MaybeObserver with one item and that the Maybe has finished sending push-based notifications.

      The Maybe will not call this method if it calls MaybeObserver.onError(java.lang.Throwable).

      Specified by:
      onSuccess in interface MaybeObserver<T>
      Parameters:
      t - the item emitted by the Maybe
    • onSubscribe

      public void onSubscribe(org.reactivestreams.Subscription s)
      Description copied from interface: FlowableSubscriber
      Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.
      Specified by:
      onSubscribe in interface FlowableSubscriber<T>
      Specified by:
      onSubscribe in interface org.reactivestreams.Subscriber<T>