Package 

Class QueueReleasingEmitterWrapper

  • All Implemented Interfaces:
    io.reactivex.rxjava3.core.Observer , io.reactivex.rxjava3.functions.Cancellable 
    
public class QueueReleasingEmitterWrapper<T>
 implements Observer<T>, Cancellable

    A convenience class to use in QueueOperation subclasses. It wraps the Emitter and QueueReleaseInterface and makes sure that the io.reactivex.rxjava3.disposables.Disposable it was subscribed to will finish and call release in either onComplete or onError in case of the wrapped emitter being unsubscribed / canceled.

    • Method Summary

      Modifier and Type Method Description
      void onComplete()
      void onError(Throwable e)
      void onSubscribe(Disposable d)
      void onNext(T t)
      synchronized void cancel()
      synchronized boolean isWrappedEmitterUnsubscribed()

      • Methods inherited from class io.reactivex.rxjava3.core.Observer

        onComplete, onError, onNext, onSubscribe

      • Methods inherited from class io.reactivex.rxjava3.functions.Cancellable

        cancel

      • Methods inherited from class java.lang.Object

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