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 classScalarSynchronousSingle.DirectScheduledEmission<T>Optimized observeOn for scalar value observed on the EventLoopsScheduler.(package private) static classScalarSynchronousSingle.NormalScheduledEmission<T>Emits a scalar value on a general scheduler.(package private) static classScalarSynchronousSingle.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 protectedScalarSynchronousSingle(T t)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> ScalarSynchronousSingle<T>create(T t)Tget()<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
-
-