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

public final Class ObservableMap<T, U>

extends AbstractObservableWithUpstream<T, U>
Class Inheritance
Imports
io.reactivex.rxjava3.annotations.Nullable, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.functions.Function, io.reactivex.rxjava3.internal.observers.BasicFuseableObserver, java.util.Objects

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ObservableMap.MapObserver<T, U>

Field Summary

Modifier and TypeField and Description
pack-priv final Function<? super T, ? extends U>
function

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

Constructor Summary

AccessConstructor and Description
public
ObservableMap(ObservableSource<T> source, Function<? super T, ? extends U> function)

Method Summary

Modifier and TypeMethod and Description
public void
subscribeActual(Observer<? super U> t)

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

Field Detail

functionback to summary
pack-priv final Function<? super T, ? extends U> function

Constructor Detail

ObservableMapback to summary
public ObservableMap(ObservableSource<T> source, Function<? super T, ? extends U> function)

Method Detail

subscribeActualback to summary
public void subscribeActual(Observer<? super U> t)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.observable back to summary

pack-priv final Class ObservableMap.MapObserver<T, U>

extends BasicFuseableObserver<T, U>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final Function<? super T, ? extends U>
mapper

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

Constructor Summary

AccessConstructor and Description
pack-priv
MapObserver(Observer<? super U> actual, Function<? super T, ? extends U> mapper)

Method Summary

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

Implements io.reactivex.rxjava3.core.Observer.onNext.

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

Implements io.reactivex.rxjava3.operators.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.rxjava3.operators.QueueFuseable.requestFusion.

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

Field Detail

mapperback to summary
pack-priv final Function<? super T, ? extends U> mapper

Constructor Detail

MapObserverback to summary
pack-priv MapObserver(Observer<? super U> actual, Function<? super T, ? extends U> mapper)

Method Detail

onNextback to summary
public void onNext(T t)

Implements io.reactivex.rxjava3.core.Observer.onNext.

Doc from io.reactivex.rxjava3.core.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 U poll() throws Throwable

Implements io.reactivex.rxjava3.operators.SimpleQueue.poll.

Doc from io.reactivex.rxjava3.operators.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:U

the item or null to indicate an empty queue

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

Implements io.reactivex.rxjava3.operators.QueueFuseable.requestFusion.

Doc from io.reactivex.rxjava3.operators.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