java.lang.Object
- io.reactivex.rxjava3.internal.observers.BasicFuseableObserver<T,T>
- - io.reactivex.rxjava3.internal.operators.observable.ObservableDistinct.DistinctObserver<T,K>

All Implemented Interfaces:

Observer<T>, Disposable, QueueDisposable<T>, QueueFuseable<T>, SimpleQueue<T>

Enclosing class:

ObservableDistinct<T,K>
```
static final class ObservableDistinct.DistinctObserver<T,K>
extends BasicFuseableObserver<T,T>
```

Field Summary

Fields
Modifier and Type Field Description

(package private) java.util.Collection<? super K> collection

(package private) Function<? super T,K> keySelector
- Fields inherited from class io.reactivex.rxjava3.internal.observers.BasicFuseableObserver
  done, downstream, qd, sourceMode, upstream
- Fields inherited from interface io.reactivex.rxjava3.operators.QueueFuseable
  ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors
Constructor	Description
`DistinctObserver(Observer<? super T> actual, Function<? super T,K> keySelector, java.util.Collection<? super K> collection)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`clear()`	Removes all enqueued items from this queue.
`void`	`onComplete()`	Notifies the `Observer` that the `Observable` has finished sending push-based notifications.
`void`	`onError(java.lang.Throwable e)`	Notifies the `Observer` that the `Observable` has experienced an error condition.
`void`	`onNext(T value)`	Provides the `Observer` with a new item to observe.
`T`	`poll()`	Tries to dequeue a value (non-null) or returns null if the queue is empty.
`int`	`requestFusion(int mode)`	Request a fusion mode from the upstream.

Methods inherited from class io.reactivex.rxjava3.internal.observers.BasicFuseableObserver
afterDownstream, beforeDownstream, dispose, fail, isDisposed, isEmpty, offer, offer, onSubscribe, transitiveBoundaryFusion

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - collection
```
final java.util.Collection<? super K> collection
```
  - keySelector
```
final Function<? super T,K> keySelector
```
- Constructor Detail
  - DistinctObserver
```
DistinctObserver(Observer<? super T> actual,
                 Function<? super T,K> keySelector,
                 java.util.Collection<? super K> collection)
```
- Method Detail
  - onNext
```
public void onNext(T value)
```
    Description copied from interface: Observer
    
    Provides the Observer with a new item to observe.
    The Observable may call this method 0 or more times.
    The Observable will not call this method again after it calls either Observer.onComplete() or Observer.onError(java.lang.Throwable).
    
    Parameters:
    
    value - the item emitted by the Observable
  - onError
```
public void onError(java.lang.Throwable e)
```
    Description copied from interface: Observer
    
    Notifies the Observer that the Observable has experienced an error condition.
    If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onComplete().
    
    Specified by:
    
    onError in interface Observer<T>
    
    Overrides:
    
    onError in class BasicFuseableObserver<T,T>
    
    Parameters:
    
    e - the exception encountered by the Observable
  - onComplete
```
public void onComplete()
```
    Description copied from interface: Observer
    
    Notifies the Observer that the Observable has finished sending push-based notifications.
    The Observable will not call this method if it calls Observer.onError(java.lang.Throwable).
    
    Specified by:
    
    onComplete in interface Observer<T>
    
    Overrides:
    
    onComplete in class BasicFuseableObserver<T,T>
  - requestFusion
```
public int requestFusion(int mode)
```
    Description copied from interface: QueueFuseable
    
    Request a fusion mode from the upstream.
    This should be called before onSubscribe returns.
    Calling this method multiple times or after onSubscribe finished is not allowed and may result in undefined behavior.
    
    Parameters:
    
    mode - the requested fusion mode, allowed values are QueueFuseable.SYNC, QueueFuseable.ASYNC, QueueFuseable.ANY combined with QueueFuseable.BOUNDARY (e.g., requestFusion(SYNC | BOUNDARY)).
    
    Returns:
    
    the established fusion mode: QueueFuseable.NONE, QueueFuseable.SYNC, QueueFuseable.ASYNC.
  - poll
```
@Nullable
public T poll()
       throws java.lang.Throwable
```
    Description copied from interface: SimpleQueue
    
    Tries to dequeue a value (non-null) or returns null if the queue is empty.
    If the producer uses SimpleQueue.offer(Object, Object) and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well.
    
    Returns:
    
    the item or null to indicate an empty queue
    
    Throws:
    
    java.lang.Throwable - if some pre-processing of the dequeued item (usually through fused functions) throws.
  - clear
```
public void clear()
```
    Description copied from interface: SimpleQueue
    
    Removes all enqueued items from this queue.
    
    Specified by:
    
    clear in interface SimpleQueue<T>
    
    Overrides:
    
    clear in class BasicFuseableObserver<T,T>

Modifier and Type	Field	Description
`(package private) java.util.Collection<? super K>`	`collection`
`(package private) Function<? super T,K>`	`keySelector`

Class ObservableDistinct.DistinctObserver<T,​K>

Field Summary

Fields inherited from class io.reactivex.rxjava3.internal.observers.BasicFuseableObserver

Fields inherited from interface io.reactivex.rxjava3.operators.QueueFuseable

Constructor Summary

Method Summary

Methods inherited from class io.reactivex.rxjava3.internal.observers.BasicFuseableObserver

Methods inherited from class java.lang.Object

Field Detail

collection

keySelector

Constructor Detail

DistinctObserver

Method Detail

onNext

onError

onComplete

requestFusion

poll

clear

Class ObservableDistinct.DistinctObserver<T,K>