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

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

Enclosing class:: FlowableThrottleFirstTimed<T>

static final class FlowableThrottleFirstTimed.DebounceTimedSubscriber<T>
extends java.util.concurrent.atomic.AtomicLong
implements FlowableSubscriber<T>, org.reactivestreams.Subscription, java.lang.Runnable

Field Summary

Fields
Modifier and Type	Field	Description
`(package private) boolean`	`done`
`(package private) org.reactivestreams.Subscriber<? super T>`	`downstream`
`(package private) boolean`	`gate`
`(package private) Consumer<? super T>`	`onDropped`
`private static long`	`serialVersionUID`
`(package private) long`	`timeout`
`(package private) SequentialDisposable`	`timer`
`(package private) java.util.concurrent.TimeUnit`	`unit`
`(package private) org.reactivestreams.Subscription`	`upstream`
`(package private) Scheduler.Worker`	`worker`

Constructor Summary

Constructors
Constructor	Description
`DebounceTimedSubscriber(org.reactivestreams.Subscriber<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancel()`
`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)`
`void`	`run()`

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
```
  - timeout
```
final long timeout
```
  - unit
```
final java.util.concurrent.TimeUnit unit
```
  - worker
```
final Scheduler.Worker worker
```
  - onDropped
```
final Consumer<? super T> onDropped
```
  - upstream
```
org.reactivestreams.Subscription upstream
```
  - timer
```
final SequentialDisposable timer
```
  - gate
```
volatile boolean gate
```
  - done
```
boolean done
```
- Constructor Detail
  - DebounceTimedSubscriber
```
DebounceTimedSubscriber(org.reactivestreams.Subscriber<? super T> actual,
                        long timeout,
                        java.util.concurrent.TimeUnit unit,
                        Scheduler.Worker worker,
                        Consumer<? super T> onDropped)
```
- 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>
  - run
```
public void run()
```
    Specified by:
    
    run in interface java.lang.Runnable
  - 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>
  - 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

Class FlowableThrottleFirstTimed.DebounceTimedSubscriber<T>

Field Summary

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Number

Methods inherited from class java.lang.Object

Field Detail

serialVersionUID

downstream

timeout

unit

worker

onDropped

upstream

timer

gate

done

Constructor Detail

DebounceTimedSubscriber

Method Detail

onSubscribe

onNext

run

onError

onComplete

request

cancel