Class FlowableFromStream.StreamSubscription<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.StreamSubscription<T>
-
- All Implemented Interfaces:
QueueFuseable<T>
,QueueSubscription<T>
,SimpleQueue<T>
,java.io.Serializable
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableFromStream<T>
static final class FlowableFromStream.StreamSubscription<T> extends FlowableFromStream.AbstractStreamSubscription<T>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) org.reactivestreams.Subscriber<? 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 StreamSubscription(org.reactivestreams.Subscriber<? 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 org.reactivestreams.Subscriber<? super T> downstream
-
-
Method Detail
-
run
public void run(long n)
- Specified by:
run
in classFlowableFromStream.AbstractStreamSubscription<T>
-
-