Modifier and Type	Class and Description
pack-priv static class	FlowableScalarXMap.ScalarXMapFlowable< the scalar value type T, the mapped Publisher's element type. R> Maps a scalar value to a Publisher and subscribes to it.

Access	Constructor and Description
private	FlowableScalarXMap() Utility class.

Method Summary

Modifier and Type	Method and Description
public static < the scalar value type T, the output value type U> Flowable<U>	Returns: the new Flowable instance scalarXMap(final T the scalar value to map value, final Function<? super T, ? extends Publisher<? extends U>> the function that gets the scalar value and should return a Publisher that gets streamed mapper) Maps a scalar value into a Publisher and emits its values.
public static < the input value type T, the output value type R> boolean	Returns: true if successful, false if the caller should continue with the regular path. tryScalarXMapSubscribe(Publisher<T> the source Publisher source, Subscriber<? super R> the subscriber subscriber, Function<? super T, ? extends Publisher<? extends R>> the function mapping a scalar value into a Publisher mapper) Tries to subscribe to a possibly Callable source's mapped Publisher.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

FlowableScalarXMap	back to summary
private FlowableScalarXMap() Utility class.

Method Detail

scalarXMap	back to summary
public static <T, U> Flowable<U> scalarXMap(final T value, final Function<? super T, ? extends Publisher<? extends U>> mapper) Maps a scalar value into a Publisher and emits its values. Parameters <T> the scalar value type <U> the output value type value:T the scalar value to map mapper:Function<? super T, ? extends Publisher<? extends U>> the function that gets the scalar value and should return a Publisher that gets streamed Returns:Flowable<U> the new Flowable instance

scalarXMap

back to summary

public static <T, U> Flowable<U> scalarXMap(final T value, final Function<? super T, ? extends Publisher<? extends U>> mapper)

Maps a scalar value into a Publisher and emits its values.

Parameters

<T>: the scalar value type
<U>: the output value type
value:T: the scalar value to map
mapper:Function<? super T, ? extends Publisher<? extends U>>: the function that gets the scalar value and should return a Publisher that gets streamed

Returns:Flowable<U>

the new Flowable instance

tryScalarXMapSubscribe	back to summary
public static <T, R> boolean tryScalarXMapSubscribe(Publisher<T> source, Subscriber<? super R> subscriber, Function<? super T, ? extends Publisher<? extends R>> mapper) Tries to subscribe to a possibly Callable source's mapped Publisher. Parameters <T> the input value type <R> the output value type source:Publisher<T> the source Publisher subscriber:Subscriber<? super R> the subscriber mapper:Function<? super T, ? extends Publisher<? extends R>> the function mapping a scalar value into a Publisher Returns:boolean true if successful, false if the caller should continue with the regular path. Annotations @SuppressWarnings:unchecked

tryScalarXMapSubscribe

back to summary

public static <T, R> boolean tryScalarXMapSubscribe(Publisher<T> source, Subscriber<? super R> subscriber, Function<? super T, ? extends Publisher<? extends R>> mapper)

Tries to subscribe to a possibly Callable source's mapped Publisher.

Parameters

<T>: the input value type
<R>: the output value type
source:Publisher<T>: the source Publisher
subscriber:Subscriber<? super R>: the subscriber
mapper:Function<? super T, ? extends Publisher<? extends R>>: the function mapping a scalar value into a Publisher

Returns:boolean

true if successful, false if the caller should continue with the regular path.

Annotations

@SuppressWarnings:unchecked

io.reactivex.internal.operators.flowable back to summary

pack-priv final Class FlowableScalarXMap.ScalarXMapFlowable<T, R>

Class Inheritance

extends Flowable<R>

java.lang.Object
io.reactivex.Flowable
io.reactivex.internal.operators.flowable.FlowableScalarXMap.ScalarXMapFlowable

Type Parameters

<T>: the scalar value type
<R>: the mapped Publisher's element type.

Maps a scalar value to a Publisher and subscribes to it.

Field Summary

Modifier and Type	Field and Description
pack-priv final Function<? super T, ? extends Publisher<? extends R>>	mapper
pack-priv final T	value

Constructor Summary

Access	Constructor and Description
pack-priv	ScalarXMapFlowable(T value, Function<? super T, ? extends Publisher<? extends R>> mapper)

Method Summary

Modifier and Type	Method and Description
public void	subscribeActual(Subscriber<? super R> the incoming Subscriber, never null s) Implements abstract io.reactivex.Flowable.subscribeActual. Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming `Subscriber`s.

Inherited from io.reactivex.Flowable:: all amb ambArray ambWith any as blockingFirst blockingFirst blockingForEach blockingIterable blockingIterable blockingLast blockingLast blockingLatest blockingMostRecent blockingNext blockingSingle blockingSingle blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer bufferSize cache cacheWithInitialCapacity cast collect collectInto combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatestDelayError combineLatestDelayError combineLatestDelayError combineLatestDelayError combineLatestDelayError combineLatestDelayError compose concat concat concat concat concat concat concatArray concatArrayDelayError concatArrayEager concatArrayEager concatArrayEagerDelayError concatArrayEagerDelayError concatDelayError concatDelayError concatDelayError concatEager concatEager concatEager concatEager concatMap concatMap concatMapCompletable concatMapCompletable concatMapCompletableDelayError concatMapCompletableDelayError concatMapCompletableDelayError concatMapDelayError concatMapDelayError concatMapEager concatMapEager concatMapEagerDelayError concatMapEagerDelayError concatMapIterable concatMapIterable concatMapMaybe concatMapMaybe concatMapMaybeDelayError concatMapMaybeDelayError concatMapMaybeDelayError concatMapSingle concatMapSingle concatMapSingleDelayError concatMapSingleDelayError concatMapSingleDelayError concatWith concatWith concatWith concatWith contains count create debounce debounce debounce defaultIfEmpty defer delay delay delay delay delay delay delaySubscription delaySubscription delaySubscription dematerialize dematerialize distinct distinct distinct distinctUntilChanged distinctUntilChanged distinctUntilChanged doAfterNext doAfterTerminate doFinally doOnCancel doOnComplete doOnEach doOnEach doOnError doOnLifecycle doOnNext doOnRequest doOnSubscribe doOnTerminate elementAt elementAt elementAtOrError empty error error filter first firstElement firstOrError flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMapCompletable flatMapCompletable flatMapIterable flatMapIterable flatMapIterable flatMapIterable flatMapMaybe flatMapMaybe flatMapSingle flatMapSingle forEach forEachWhile forEachWhile forEachWhile fromArray fromCallable fromFuture fromFuture fromFuture fromFuture fromIterable fromPublisher generate generate generate generate generate groupBy groupBy groupBy groupBy groupBy groupBy groupJoin hide ignoreElements interval interval interval interval intervalRange intervalRange isEmpty join just just just just just just just just just just last lastElement lastOrError lift limit map materialize merge merge merge merge merge merge merge merge mergeArray mergeArray mergeArrayDelayError mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith mergeWith mergeWith mergeWith never observeOn observeOn observeOn ofType onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureDrop onBackpressureDrop onBackpressureLatest onErrorResumeNext onErrorResumeNext onErrorReturn onErrorReturnItem onExceptionResumeNext onTerminateDetach parallel parallel parallel publish publish publish publish range rangeLong rebatchRequests reduce reduce reduceWith repeat repeat repeatUntil repeatWhen replay replay replay replay replay replay replay replay replay replay replay replay replay replay replay replay retry retry retry retry retry retryUntil retryWhen safeSubscribe sample sample sample sample sample sample scan scan scanWith sequenceEqual sequenceEqual sequenceEqual sequenceEqual serialize share single singleElement singleOrError skip skip skip skipLast skipLast skipLast skipLast skipLast skipLast skipUntil skipWhile sorted sorted startWith startWith startWith startWithArray subscribe subscribe subscribe subscribe subscribe subscribe subscribe subscribeOn subscribeOn subscribeWith switchIfEmpty switchMap switchMap switchMapCompletable switchMapCompletableDelayError switchMapDelayError switchMapDelayError switchMapMaybe switchMapMaybeDelayError switchMapSingle switchMapSingleDelayError switchOnNext switchOnNext switchOnNextDelayError switchOnNextDelayError take take take takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeUntil takeUntil takeWhile test test test throttleFirst throttleFirst throttleLast throttleLast throttleLatest throttleLatest throttleLatest throttleLatest throttleWithTimeout throttleWithTimeout timeInterval timeInterval timeInterval timeInterval timeout timeout timeout timeout timeout timeout timeout timeout timer timer timestamp timestamp timestamp timestamp to toFuture toList toList toList toMap toMap toMap toMultimap toMultimap toMultimap toMultimap toObservable toSortedList toSortedList toSortedList toSortedList unsafeCreate unsubscribeOn using using window window window window window window window window window window window window window window window window window window window withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom zip zip zip zip zip zip zip zip zip zip zip zip zipArray zipIterable zipWith zipWith zipWith zipWith

Field Detail

mapper	back to summary
pack-priv final Function<? super T, ? extends Publisher<? extends R>> mapper

value	back to summary
pack-priv final T value

Constructor Detail

ScalarXMapFlowable	back to summary
pack-priv ScalarXMapFlowable(T value, Function<? super T, ? extends Publisher<? extends R>> mapper)

Method Detail

subscribeActual back to summary

subscribeActual	back to summary
public void subscribeActual(Subscriber<? super R> s) Implements abstract io.reactivex.Flowable.subscribeActual. Doc from io.reactivex.Flowable.subscribeActual. Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming `Subscriber`s. There is no need to call any of the plugin hooks on the current `Flowable` instance or the `Subscriber`; all hooks and basic safeguards have been applied by `subscribe(Subscriber)` before this method gets called. Parameters s:Subscriber<? super R> the incoming Subscriber, never null Annotations @SuppressWarnings:unchecked @Override

public void subscribeActual(Subscriber<? super R> s)

Implements abstract io.reactivex.Flowable.subscribeActual.

Doc from io.reactivex.Flowable.subscribeActual.

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

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

Parameters

s:Subscriber<? super R>: the incoming Subscriber, never null

Annotations

@SuppressWarnings:unchecked
@Override

public final Class FlowableScalarXMap

Nested and Inner Type Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class FlowableScalarXMap.ScalarXMapFlowable<T, R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail