Class ObservableGenerate.GeneratorDisposable<T,S>
java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableGenerate.GeneratorDisposable<T,S>
- All Implemented Interfaces:
Emitter<T>
,Disposable
- Enclosing class:
ObservableGenerate<T,
S>
static final class ObservableGenerate.GeneratorDisposable<T,S>
extends Object
implements Emitter<T>, Disposable
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
downstream
-
generator
-
disposeState
-
state
S state -
cancelled
volatile boolean cancelled -
terminate
boolean terminate -
hasNext
boolean hasNext
-
-
Constructor Details
-
GeneratorDisposable
-
-
Method Details
-
run
public void run() -
dispose
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-
onNext
Description copied from interface:Emitter
Signal a normal value. -
onError
Description copied from interface:Emitter
Signal aThrowable
exception. -
onComplete
public void onComplete()Description copied from interface:Emitter
Signal a completion.- Specified by:
onComplete
in interfaceEmitter<T>
-