Class ObservableGenerate.GeneratorDisposable<T,​S>

    • Field Detail

      • downstream

        final Observer<? super T> downstream
      • disposeState

        final Consumer<? super S> disposeState
      • state

        S state
      • cancelled

        volatile boolean cancelled
      • terminate

        boolean terminate
      • hasNext

        boolean hasNext
    • Method Detail

      • run

        public void run()
      • dispose

        private void dispose​(S s)
      • dispose

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

        public boolean isDisposed()
        Description copied from interface: Disposable
        Returns true if this resource has been disposed.
        Specified by:
        isDisposed in interface Disposable
        Returns:
        true if this resource has been disposed
      • onNext

        public void onNext​(T t)
        Description copied from interface: Emitter
        Signal a normal value.
        Specified by:
        onNext in interface Emitter<T>
        Parameters:
        t - the value to signal, not null
      • onError

        public void onError​(java.lang.Throwable t)
        Description copied from interface: Emitter
        Signal a Throwable exception.
        Specified by:
        onError in interface Emitter<T>
        Parameters:
        t - the Throwable to signal, not null
      • onComplete

        public void onComplete()
        Description copied from interface: Emitter
        Signal a completion.
        Specified by:
        onComplete in interface Emitter<T>