java.lang.Object
- java.lang.Number
- - java.util.concurrent.atomic.AtomicInteger
  - - io.reactivex.rxjava3.internal.operators.flowable.FlowableScanSeed.ScanSeedSubscriber<T,R>

All Implemented Interfaces:: FlowableSubscriber<T>, java.io.Serializable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Enclosing class:: FlowableScanSeed<T,R>

static final class FlowableScanSeed.ScanSeedSubscriber<T,R>
extends java.util.concurrent.atomic.AtomicInteger
implements FlowableSubscriber<T>, org.reactivestreams.Subscription

Field Summary

Fields
Modifier and Type	Field	Description
`(package private) BiFunction<R,? super T,R>`	`accumulator`
`(package private) boolean`	`cancelled`
`(package private) int`	`consumed`
`(package private) boolean`	`done`
`(package private) org.reactivestreams.Subscriber<? super R>`	`downstream`
`(package private) java.lang.Throwable`	`error`
`(package private) int`	`limit`
`(package private) int`	`prefetch`
`(package private) SimplePlainQueue<R>`	`queue`
`(package private) java.util.concurrent.atomic.AtomicLong`	`requested`
`private static long`	`serialVersionUID`
`(package private) org.reactivestreams.Subscription`	`upstream`
`(package private) R`	`value`

Constructor Summary

Constructors
Constructor	Description
`ScanSeedSubscriber(org.reactivestreams.Subscriber<? super R> actual, BiFunction<R,? super T,R> accumulator, R value, int prefetch)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancel()`
`(package private) void`	`drain()`
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable t)`
`void`	`onNext(T 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)`.
`void`	`request(long n)`

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
  - downstream
```
final org.reactivestreams.Subscriber<? super R> downstream
```
  - accumulator
```
final BiFunction<R,? super T,R> accumulator
```
  - queue
```
final SimplePlainQueue<R> queue
```
  - requested
```
final java.util.concurrent.atomic.AtomicLong requested
```
  - prefetch
```
final int prefetch
```
  - limit
```
final int limit
```
  - cancelled
```
volatile boolean cancelled
```
  - done
```
volatile boolean done
```
  - error
```
java.lang.Throwable error
```
  - upstream
```
org.reactivestreams.Subscription upstream
```
  - value
```
R value
```
  - consumed
```
int consumed
```
- Constructor Detail
  - ScanSeedSubscriber
```
ScanSeedSubscriber(org.reactivestreams.Subscriber<? super R> actual,
                   BiFunction<R,? super T,R> accumulator,
                   R value,
                   int prefetch)
```
- 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<T>
    
    Specified by:
    
    onSubscribe in interface org.reactivestreams.Subscriber<T>
  - onNext
```
public void onNext(T t)
```
    Specified by:
    
    onNext in interface org.reactivestreams.Subscriber<T>
  - onError
```
public void onError(java.lang.Throwable t)
```
    Specified by:
    
    onError in interface org.reactivestreams.Subscriber<T>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface org.reactivestreams.Subscriber<T>
  - cancel
```
public void cancel()
```
    Specified by:
    
    cancel in interface org.reactivestreams.Subscription
  - request
```
public void request(long n)
```
    Specified by:
    
    request in interface org.reactivestreams.Subscription
  - drain
```
void drain()
```

Class FlowableScanSeed.ScanSeedSubscriber<T,​R>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.util.concurrent.atomic.AtomicInteger

Methods inherited from class java.lang.Number

Methods inherited from class java.lang.Object

Field Detail

serialVersionUID

downstream

accumulator

queue

requested

prefetch

limit

cancelled

done

error

upstream

value

consumed

Constructor Detail

ScanSeedSubscriber

Method Detail

onSubscribe

onNext

onError

onComplete

cancel

request

drain

Class FlowableScanSeed.ScanSeedSubscriber<T,R>