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

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

Enclosing class:: FlowableTimeoutTimed<T>

static final class FlowableTimeoutTimed.TimeoutSubscriber<T>
extends java.util.concurrent.atomic.AtomicLong
implements FlowableSubscriber<T>, org.reactivestreams.Subscription, FlowableTimeoutTimed.TimeoutSupport

Field Summary

Fields
Modifier and Type	Field	Description
`(package private) org.reactivestreams.Subscriber<? super T>`	`downstream`
`(package private) java.util.concurrent.atomic.AtomicLong`	`requested`
`private static long`	`serialVersionUID`
`(package private) SequentialDisposable`	`task`
`(package private) long`	`timeout`
`(package private) java.util.concurrent.TimeUnit`	`unit`
`(package private) java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription>`	`upstream`
`(package private) Scheduler.Worker`	`worker`

Constructor Summary

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

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`	`onTimeout(long idx)`
`void`	`request(long n)`
`(package private) void`	`startTimeout(long nextIndex)`

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
```
  - task
```
final SequentialDisposable task
```
  - upstream
```
final java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> upstream
```
  - requested
```
final java.util.concurrent.atomic.AtomicLong requested
```
- Constructor Detail
  - TimeoutSubscriber
```
TimeoutSubscriber(org.reactivestreams.Subscriber<? super T> actual,
                  long timeout,
                  java.util.concurrent.TimeUnit unit,
                  Scheduler.Worker worker)
```
- 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>
  - startTimeout
```
void startTimeout(long nextIndex)
```
  - 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>
  - onTimeout
```
public void onTimeout(long idx)
```
    Specified by:
    
    onTimeout in interface FlowableTimeoutTimed.TimeoutSupport
  - 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 FlowableTimeoutTimed.TimeoutSubscriber<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

task

upstream

requested

Constructor Detail

TimeoutSubscriber

Method Detail

onSubscribe

onNext

startTimeout

onError

onComplete

onTimeout

request

cancel