Class OperatorSwitch.SwitchSubscriber<T>

    • Field Detail

      • delayError

        final boolean delayError
      • index

        final java.util.concurrent.atomic.AtomicLong index
      • emitting

        boolean emitting
      • missed

        boolean missed
      • requested

        long requested
      • mainDone

        volatile boolean mainDone
      • error

        java.lang.Throwable error
      • innerActive

        boolean innerActive
      • TERMINAL_ERROR

        static final java.lang.Throwable TERMINAL_ERROR
    • Constructor Detail

      • SwitchSubscriber

        SwitchSubscriber​(Subscriber<? super T> child,
                         boolean delayError)
    • Method Detail

      • init

        void init()
      • clearProducer

        void clearProducer()
      • onError

        public void onError​(java.lang.Throwable e)
        Description copied from interface: Observer
        Notifies the Observer that the Observable has experienced an error condition.

        If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onCompleted().

        Parameters:
        e - the exception encountered by the Observable
      • updateError

        boolean updateError​(java.lang.Throwable next)
      • error

        void error​(java.lang.Throwable e,
                   long id)
      • complete

        void complete​(long id)
      • pluginError

        void pluginError​(java.lang.Throwable e)
      • innerProducer

        void innerProducer​(Producer p,
                           long id)
      • childRequested

        void childRequested​(long n)
      • drain

        void drain()
      • checkTerminated

        protected boolean checkTerminated​(boolean localMainDone,
                                          boolean localInnerActive,
                                          java.lang.Throwable localError,
                                          SpscLinkedArrayQueue<java.lang.Object> localQueue,
                                          Subscriber<? super T> localChild,
                                          boolean empty)