Class MaybeConcatArray.ConcatMaybeObserver<T>

  • All Implemented Interfaces:
    MaybeObserver<T>, java.io.Serializable, org.reactivestreams.Subscription
    Enclosing class:
    MaybeConcatArray<T>

    static final class MaybeConcatArray.ConcatMaybeObserver<T>
    extends java.util.concurrent.atomic.AtomicInteger
    implements MaybeObserver<T>, org.reactivestreams.Subscription
    • Constructor Summary

      Constructors 
      Constructor Description
      ConcatMaybeObserver​(org.reactivestreams.Subscriber<? super T> actual, MaybeSource<? extends T>[] sources)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      (package private) void drain()  
      void onComplete()
      Called once the deferred computation completes normally.
      void onError​(java.lang.Throwable e)
      Notifies the MaybeObserver that the Maybe has experienced an error condition.
      void onSubscribe​(Disposable d)
      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.
      void onSuccess​(T value)
      Notifies the MaybeObserver with one item and that the Maybe has finished sending push-based notifications.
      void request​(long n)  
      • Methods inherited from class java.util.concurrent.atomic.AtomicInteger

        accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
      • Methods inherited from class java.lang.Number

        byteValue, shortValue
      • Methods inherited from class java.lang.Object

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

      • downstream

        final org.reactivestreams.Subscriber<? super T> downstream
      • requested

        final java.util.concurrent.atomic.AtomicLong requested
      • current

        final java.util.concurrent.atomic.AtomicReference<java.lang.Object> current
      • index

        int index
      • produced

        long produced
    • Constructor Detail

      • ConcatMaybeObserver

        ConcatMaybeObserver​(org.reactivestreams.Subscriber<? super T> actual,
                            MaybeSource<? extends T>[] sources)
    • Method Detail

      • 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
      • onComplete

        public void onComplete()
        Description copied from interface: MaybeObserver
        Called once the deferred computation completes normally.
        Specified by:
        onComplete in interface MaybeObserver<T>
      • drain

        void drain()