FlowableCreate.LatestAsyncEmitter

java.lang.Object
- java.lang.Number
- - java.util.concurrent.atomic.AtomicLong
  - - io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter<T>
    - - io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.LatestAsyncEmitter<T>

All Implemented Interfaces:

Emitter<T>, FlowableEmitter<T>, java.io.Serializable, org.reactivestreams.Subscription

Enclosing class:

FlowableCreate<T>
```
static final class FlowableCreate.LatestAsyncEmitter<T>
extends FlowableCreate.BaseEmitter<T>
```

Field Summary

Fields
Modifier and Type	Field	Description
`(package private) boolean`	`done`
`(package private) java.lang.Throwable`	`error`
`(package private) java.util.concurrent.atomic.AtomicReference<T>`	`queue`
`private static long`	`serialVersionUID`
`(package private) java.util.concurrent.atomic.AtomicInteger`	`wip`

Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter
downstream, serial

Constructor Summary

Constructors
Constructor Description

LatestAsyncEmitter(org.reactivestreams.Subscriber<? super T> downstream)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`(package private) void`	`drain()`
`void`	`onComplete()`	Signal a completion.
`void`	`onNext(T t)`	Signal a normal value.
`(package private) void`	`onRequested()`
`(package private) void`	`onUnsubscribed()`
`boolean`	`signalError(java.lang.Throwable e)`

Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter
cancel, completeDownstream, errorDownstream, isCancelled, onError, request, requested, serialize, setCancellable, setDisposable, toString, tryOnError

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, 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
  - queue
```
final java.util.concurrent.atomic.AtomicReference<T> queue
```
  - error
```
java.lang.Throwable error
```
  - done
```
volatile boolean done
```
  - wip
```
final java.util.concurrent.atomic.AtomicInteger wip
```
- Constructor Detail
  - LatestAsyncEmitter
```
LatestAsyncEmitter(org.reactivestreams.Subscriber<? super T> downstream)
```
- Method Detail
  - onNext
```
public void onNext(T t)
```
    Description copied from interface: Emitter
    
    Signal a normal value.
    
    Parameters:
    
    t - the value to signal, not null
  - signalError
```
public boolean signalError(java.lang.Throwable e)
```
    Overrides:
    
    signalError in class FlowableCreate.BaseEmitter<T>
  - onComplete
```
public void onComplete()
```
    Description copied from interface: Emitter
    
    Signal a completion.
    
    Specified by:
    
    onComplete in interface Emitter<T>
    
    Overrides:
    
    onComplete in class FlowableCreate.BaseEmitter<T>
  - onRequested
```
void onRequested()
```
    Overrides:
    
    onRequested in class FlowableCreate.BaseEmitter<T>
  - onUnsubscribed
```
void onUnsubscribed()
```
    Overrides:
    
    onUnsubscribed in class FlowableCreate.BaseEmitter<T>
  - drain
```
void drain()
```