Class FlowableGenerate.GeneratorSubscription<T,S>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
io.reactivex.rxjava3.internal.operators.flowable.FlowableGenerate.GeneratorSubscription<T,S>
- All Implemented Interfaces:
Emitter<T>
,Serializable
,org.reactivestreams.Subscription
- Enclosing class:
FlowableGenerate<T,
S>
static final class FlowableGenerate.GeneratorSubscription<T,S>
extends AtomicLong
implements Emitter<T>, org.reactivestreams.Subscription
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionGeneratorSubscription
(org.reactivestreams.Subscriber<? super T> actual, BiFunction<S, ? super Emitter<T>, S> generator, Consumer<? super S> disposeState, S initialState) -
Method Summary
Methods inherited from class java.util.concurrent.atomic.AtomicLong
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
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
downstream
-
generator
-
disposeState
-
state
S state -
cancelled
volatile boolean cancelled -
terminate
boolean terminate -
hasNext
boolean hasNext
-
-
Constructor Details
-
GeneratorSubscription
-
-
Method Details
-
request
public void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
dispose
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
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>
-