Top Inners Fields Constructors Methods
io.reactivex.internal.operators.observable

public final Class ObservableFilter<T>

extends AbstractObservableWithUpstream<T, T>
Class Inheritance
Imports
io.reactivex.*, io.reactivex.annotations.Nullable, io.reactivex.functions.Predicate, io.reactivex.internal.observers.BasicFuseableObserver

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ObservableFilter.FilterObserver<T>

Field Summary

Modifier and TypeField and Description
pack-priv final Predicate<? super T>
predicate

Inherited from io.reactivex.internal.operators.observable.AbstractObservableWithUpstream:
source

Constructor Summary

AccessConstructor and Description
public
ObservableFilter(ObservableSource<T> source, Predicate<? super T> predicate)

Method Summary

Modifier and TypeMethod and Description
public void
subscribeActual(Observer<? super T>
the incoming Observer, never null
observer)

Implements abstract io.reactivex.Observable.subscribeActual.

Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Observers.
Inherited from io.reactivex.internal.operators.observable.AbstractObservableWithUpstream:
source

Field Detail

predicateback to summary
pack-priv final Predicate<? super T> predicate

Constructor Detail

ObservableFilterback to summary
public ObservableFilter(ObservableSource<T> source, Predicate<? super T> predicate)

Method Detail

subscribeActualback to summary
public void subscribeActual(Observer<? super T> observer)

Implements abstract io.reactivex.Observable.subscribeActual.

Doc from io.reactivex.Observable.subscribeActual.

Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Observers.

There is no need to call any of the plugin hooks on the current Observable instance or the Observer; all hooks and basic safeguards have been applied by subscribe(Observer) before this method gets called.

Parameters
observer:Observer<? super T>

the incoming Observer, never null

Annotations
@Override
io.reactivex.internal.operators.observable back to summary

pack-priv final Class ObservableFilter.FilterObserver<T>

extends BasicFuseableObserver<T, T>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final Predicate<? super T>
filter

Inherited from io.reactivex.internal.observers.BasicFuseableObserver:
donedownstreamqdsourceModeupstream

Constructor Summary

AccessConstructor and Description
pack-priv
FilterObserver(Observer<? super T> actual, Predicate<? super T> filter)

Method Summary

Modifier and TypeMethod and Description
public void
onNext(T
the item emitted by the Observable
t)

Implements io.reactivex.Observer.onNext.

Provides the Observer with a new item to observe.
public T
poll()

Implements io.reactivex.internal.fuseable.SimpleQueue.poll.

Tries to dequeue a value (non-null) or returns null if the queue is empty.
public int
requestFusion(int
the requested fusion mode, allowed values are SYNC, ASYNC, ANY combined with BOUNDARY (e.g., requestFusion(SYNC | BOUNDARY)).
mode)

Implements io.reactivex.internal.fuseable.QueueFuseable.requestFusion.

Request a fusion mode from the upstream.
Inherited from io.reactivex.internal.observers.BasicFuseableObserver:
afterDownstreambeforeDownstreamcleardisposefailisDisposedisEmptyofferofferonCompleteonErroronSubscribetransitiveBoundaryFusion

Field Detail

filterback to summary
pack-priv final Predicate<? super T> filter

Constructor Detail

FilterObserverback to summary
pack-priv FilterObserver(Observer<? super T> actual, Predicate<? super T> filter)

Method Detail

onNextback to summary
public void onNext(T t)

Implements io.reactivex.Observer.onNext.

Doc from io.reactivex.Observer.onNext.

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 onComplete or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override
pollback to summary
public T poll() throws Exception

Implements io.reactivex.internal.fuseable.SimpleQueue.poll.

Doc from io.reactivex.internal.fuseable.SimpleQueue.poll.

Tries to dequeue a value (non-null) or returns null if the queue is empty.

If the producer uses 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:T

the item or null to indicate an empty queue

Annotations
@Nullable
@Override
Exceptions
Exception:
if some pre-processing of the dequeued item (usually through fused functions) throws.
requestFusionback to summary
public int requestFusion(int mode)

Implements io.reactivex.internal.fuseable.QueueFuseable.requestFusion.

Doc from io.reactivex.internal.fuseable.QueueFuseable.requestFusion.

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:int

the requested fusion mode, allowed values are SYNC, ASYNC, ANY combined with BOUNDARY (e.g., requestFusion(SYNC | BOUNDARY)).

Returns:int

the established fusion mode: NONE, SYNC, ASYNC.

Annotations
@Override