FlowablePublish.InnerSubscription

java.lang.Object
- java.lang.Number
- - java.util.concurrent.atomic.AtomicLong
  - - io.reactivex.rxjava3.internal.operators.flowable.FlowablePublish.InnerSubscription<T>

All Implemented Interfaces:: java.io.Serializable, org.reactivestreams.Subscription

Enclosing class:: FlowablePublish<T>

static final class FlowablePublish.InnerSubscription<T>
extends java.util.concurrent.atomic.AtomicLong
implements org.reactivestreams.Subscription

Field Summary

Fields
Modifier and Type	Field	Description
`(package private) org.reactivestreams.Subscriber<? super T>`	`downstream`
`(package private) long`	`emitted`
`(package private) FlowablePublish.PublishConnection<T>`	`parent`
`private static long`	`serialVersionUID`

Constructor Summary

Constructors
Constructor Description

InnerSubscription(org.reactivestreams.Subscriber<? super T> downstream, FlowablePublish.PublishConnection<T> parent)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

void cancel()

boolean isCancelled()

void request(long n)
- 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
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

serialVersionUID
```
private static final long serialVersionUID
```
See Also:

Constant Field Values

downstream

final org.reactivestreams.Subscriber<? super T> downstream

parent

final FlowablePublish.PublishConnection<T> parent

emitted
```
long emitted
```

Constructor Detail

InnerSubscription

InnerSubscription(org.reactivestreams.Subscriber<? super T> downstream,
                  FlowablePublish.PublishConnection<T> parent)

Method Detail
- request
```
public void request(long n)
```
  Specified by:
  
  request in interface org.reactivestreams.Subscription
- cancel
```
public void cancel()
```
  Specified by:
  
  cancel in interface org.reactivestreams.Subscription
- isCancelled
```
public boolean isCancelled()
```