Package rx.internal.util
Class ScalarSynchronousSingle<T>
- java.lang.Object
-
- rx.Single<T>
-
- rx.internal.util.ScalarSynchronousSingle<T>
-
public final class ScalarSynchronousSingle<T> extends Single<T>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
ScalarSynchronousSingle.DirectScheduledEmission<T>
Optimized observeOn for scalar value observed on the EventLoopsScheduler.(package private) static class
ScalarSynchronousSingle.NormalScheduledEmission<T>
Emits a scalar value on a general scheduler.(package private) static class
ScalarSynchronousSingle.ScalarSynchronousSingleAction<T>
Action that emits a single value when called.-
Nested classes/interfaces inherited from class rx.Single
Single.OnSubscribe<T>, Single.Transformer<T,R>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
ScalarSynchronousSingle(T t)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> ScalarSynchronousSingle<T>
create(T t)
T
get()
<R> Single<R>
scalarFlatMap(Func1<? super T,? extends Single<? extends R>> func)
Single<T>
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 Detail
-
value
final T value
-
-
Constructor Detail
-
ScalarSynchronousSingle
protected ScalarSynchronousSingle(T t)
-
-
Method Detail
-
create
public static <T> ScalarSynchronousSingle<T> create(T t)
-
get
public T get()
-
scalarScheduleOn
public Single<T> scalarScheduleOn(Scheduler scheduler)
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
-
-