Class FlowableFromStream.StreamConditionalSubscription<T>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicLong
-
- io.reactivex.rxjava3.internal.jdk8.FlowableFromStream.AbstractStreamSubscription<T>
-
- io.reactivex.rxjava3.internal.jdk8.FlowableFromStream.StreamConditionalSubscription<T>
-
- All Implemented Interfaces:
QueueFuseable<T>
,QueueSubscription<T>
,SimpleQueue<T>
,java.io.Serializable
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableFromStream<T>
static final class FlowableFromStream.StreamConditionalSubscription<T> extends FlowableFromStream.AbstractStreamSubscription<T>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) ConditionalSubscriber<? super T>
downstream
private static long
serialVersionUID
-
Fields inherited from class io.reactivex.rxjava3.internal.jdk8.FlowableFromStream.AbstractStreamSubscription
cancelled, closeable, iterator, once
-
-
Constructor Summary
Constructors Constructor Description StreamConditionalSubscription(ConditionalSubscriber<? super T> downstream, java.util.Iterator<T> iterator, java.lang.AutoCloseable closeable)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
run(long n)
-
Methods inherited from class io.reactivex.rxjava3.internal.jdk8.FlowableFromStream.AbstractStreamSubscription
cancel, clear, isEmpty, offer, offer, poll, request, requestFusion
-
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
downstream
final ConditionalSubscriber<? super T> downstream
-
-
Constructor Detail
-
StreamConditionalSubscription
StreamConditionalSubscription(ConditionalSubscriber<? super T> downstream, java.util.Iterator<T> iterator, java.lang.AutoCloseable closeable)
-
-
Method Detail
-
run
public void run(long n)
- Specified by:
run
in classFlowableFromStream.AbstractStreamSubscription<T>
-
-