Package rx.internal.util
Class ScalarSynchronousSingle<T>
java.lang.Object
rx.Single<T>
rx.internal.util.ScalarSynchronousSingle<T>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
Optimized observeOn for scalar value observed on the EventLoopsScheduler.(package private) static final class
Emits a scalar value on a general scheduler.(package private) static final class
Action that emits a single value when called.Nested classes/interfaces inherited from class rx.Single
Single.OnSubscribe<T>, Single.Transformer<T,
R> -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> ScalarSynchronousSingle
<T> create
(T t) get()
<R> Single
<R> scalarFlatMap
(Func1<? super T, ? extends Single<? extends R>> func) scalarScheduleOn
(Scheduler scheduler) Customized observeOn/subscribeOn implementation which emits the scalar value directly or with less overhead on the specified scheduler.Methods inherited from class rx.Single
compose, concat, concat, concat, concat, concat, concat, concat, concat, concatWith, create, defer, delay, delay, delaySubscription, doAfterTerminate, doOnError, doOnSubscribe, doOnSuccess, doOnUnsubscribe, error, flatMap, flatMapObservable, from, from, from, fromCallable, just, lift, map, merge, merge, merge, merge, merge, merge, merge, merge, merge, mergeWith, observeOn, onErrorResumeNext, onErrorResumeNext, onErrorReturn, retry, retry, retry, retryWhen, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, takeUntil, takeUntil, takeUntil, timeout, timeout, timeout, timeout, toBlocking, toCompletable, toObservable, unsafeSubscribe, using, using, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith
-
Field Details
-
value
-
-
Constructor Details
-
ScalarSynchronousSingle
-
-
Method Details
-
create
-
get
-
scalarScheduleOn
Customized observeOn/subscribeOn implementation which emits the scalar value directly or with less overhead on the specified scheduler.- Parameters:
scheduler
- the target scheduler- Returns:
- the new observable
-
scalarFlatMap
-