FlowableConcatMap.ConcatMapInner

java.lang.Object
- java.lang.Number
- - java.util.concurrent.atomic.AtomicInteger
  - - io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter
    - - io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMap.ConcatMapInner<R>

All Implemented Interfaces:

FlowableSubscriber<R>, java.io.Serializable, org.reactivestreams.Subscriber<R>, org.reactivestreams.Subscription

Enclosing class:

FlowableConcatMap<T,R>
```
static final class FlowableConcatMap.ConcatMapInner<R>
extends SubscriptionArbiter
implements FlowableSubscriber<R>
```

Field Summary

Fields
Modifier and Type Field Description

(package private) FlowableConcatMap.ConcatMapSupport<R> parent

(package private) long produced

private static long serialVersionUID
- Fields inherited from class io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter
  unbounded

Constructor Summary

Constructors
Constructor Description

ConcatMapInner(FlowableConcatMap.ConcatMapSupport<R> parent)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable t)`
`void`	`onNext(R t)`
`void`	`onSubscribe(org.reactivestreams.Subscription s)`	Implementors of this method should make sure everything that needs to be visible in `Subscriber.onNext(Object)` is established before calling `Subscription.request(long)`.

Methods inherited from class io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter
cancel, isCancelled, isUnbounded, produced, request, setSubscription

Methods inherited from class java.util.concurrent.atomic.AtomicInteger
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
  - parent
```
final FlowableConcatMap.ConcatMapSupport<R> parent
```
  - produced
```
long produced
```
- Constructor Detail
  - ConcatMapInner
```
ConcatMapInner(FlowableConcatMap.ConcatMapSupport<R> parent)
```
- Method Detail
  - onSubscribe
```
public void onSubscribe(org.reactivestreams.Subscription s)
```
    Description copied from interface: FlowableSubscriber
    
    Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.
    
    Specified by:
    
    onSubscribe in interface FlowableSubscriber<R>
    
    Specified by:
    
    onSubscribe in interface org.reactivestreams.Subscriber<R>
  - onNext
```
public void onNext(R t)
```
    Specified by:
    
    onNext in interface org.reactivestreams.Subscriber<R>
  - onError
```
public void onError(java.lang.Throwable t)
```
    Specified by:
    
    onError in interface org.reactivestreams.Subscriber<R>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface org.reactivestreams.Subscriber<R>