Class MaybeCreate.Emitter<T>

    • Constructor Summary

      Constructors 
      Constructor Description
      Emitter​(MaybeObserver<? super T> downstream)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void dispose()
      Dispose the resource, the operation should be idempotent.
      boolean isDisposed()
      Returns true if the downstream disposed the sequence or the emitter was terminated via MaybeEmitter.onSuccess(Object), MaybeEmitter.onError(Throwable), MaybeEmitter.onComplete() or a successful MaybeEmitter.tryOnError(Throwable).
      void onComplete()
      Signal the completion.
      void onError​(java.lang.Throwable t)
      Signal an exception.
      void onSuccess​(T value)
      Signal a success value.
      void setCancellable​(Cancellable c)
      Sets a Cancellable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
      void setDisposable​(Disposable d)
      Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
      java.lang.String toString()  
      boolean tryOnError​(java.lang.Throwable t)
      Attempts to emit the specified Throwable error if the downstream hasn't cancelled the sequence or is otherwise terminated, returning false if the emission is not allowed to happen due to lifecycle restrictions.
      • Methods inherited from class java.util.concurrent.atomic.AtomicReference

        accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Method Detail

      • onSuccess

        public void onSuccess​(T value)
        Description copied from interface: MaybeEmitter
        Signal a success value.
        Specified by:
        onSuccess in interface MaybeEmitter<T>
        Parameters:
        value - the value, not null
      • onError

        public void onError​(java.lang.Throwable t)
        Description copied from interface: MaybeEmitter
        Signal an exception.
        Specified by:
        onError in interface MaybeEmitter<T>
        Parameters:
        t - the exception, not null
      • tryOnError

        public boolean tryOnError​(java.lang.Throwable t)
        Description copied from interface: MaybeEmitter
        Attempts to emit the specified Throwable error if the downstream hasn't cancelled the sequence or is otherwise terminated, returning false if the emission is not allowed to happen due to lifecycle restrictions.

        Unlike MaybeEmitter.onError(Throwable), the RxjavaPlugins.onError is not called if the error could not be delivered.

        History: 2.1.1 - experimental

        Specified by:
        tryOnError in interface MaybeEmitter<T>
        Parameters:
        t - the Throwable error to signal if possible
        Returns:
        true if successful, false if the downstream is not able to accept further events
      • setDisposable

        public void setDisposable​(Disposable d)
        Description copied from interface: MaybeEmitter
        Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.

        This method is thread-safe.

        Specified by:
        setDisposable in interface MaybeEmitter<T>
        Parameters:
        d - the disposable, null is allowed
      • setCancellable

        public void setCancellable​(Cancellable c)
        Description copied from interface: MaybeEmitter
        Sets a Cancellable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.

        This method is thread-safe.

        Specified by:
        setCancellable in interface MaybeEmitter<T>
        Parameters:
        c - the Cancellable resource, null is allowed
      • dispose

        public void dispose()
        Description copied from interface: Disposable
        Dispose the resource, the operation should be idempotent.
        Specified by:
        dispose in interface Disposable
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.util.concurrent.atomic.AtomicReference<Disposable>