Top Inners Fields Constructors Methods
rx.internal.util

public final Class ScalarSynchronousSingle<T>

extends Single<T>
Class Inheritance
Imports
rx.*, .Scheduler.Worker, rx.functions.*, rx.internal.schedulers.EventLoopsScheduler

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ScalarSynchronousSingle.DirectScheduledEmission<T>

Optimized observeOn for scalar value observed on the EventLoopsScheduler.

pack-priv static class
ScalarSynchronousSingle.NormalScheduledEmission<T>

Emits a scalar value on a general scheduler.

pack-priv static class
ScalarSynchronousSingle.ScalarSynchronousSingleAction<T>

Action that emits a single value when called.

Field Summary

Modifier and TypeField and Description
pack-priv final T
value

Constructor Summary

AccessConstructor and Description
protected
ScalarSynchronousSingle(final T t)

Method Summary

Modifier and TypeMethod and Description
public static <T> ScalarSynchronousSingle<T>
create(T t)

public T
get()

public <R> Single<R>
scalarFlatMap(final Func1<? super T, ? extends Single<? extends R>> func)

public Single<T>

Returns:

the new observable
scalarScheduleOn(Scheduler
the target scheduler
scheduler)

Customized observeOn/subscribeOn implementation which emits the scalar value directly or with less overhead on the specified scheduler.

Inherited from rx.Single:
cachecastcomposeconcatconcatconcatconcatconcatconcatconcatconcatconcatWithcreatedeferdelaydelaydelaySubscriptiondoAfterTerminatedoOnEachdoOnErrordoOnSubscribedoOnSuccessdoOnUnsubscribeerrorflatMapflatMapCompletableflatMapObservablefromfromfromfromCallablefromEmitterjustliftmapmergemergemergemergemergemergemergemergemergemergemergemergeDelayErrormergeDelayErrormergeWithobserveOnonErrorResumeNextonErrorResumeNextonErrorReturnretryretryretryretryWhensubscribesubscribesubscribesubscribesubscribesubscribesubscribeOntakeUntiltakeUntiltakeUntiltesttimeouttimeouttimeouttimeouttotoBlockingtoCompletabletoObservableunsafeSubscribeunsubscribeOnusingusingzipzipzipzipzipzipzipzipzipzipWith

Field Detail

valueback to summary
pack-priv final T value

Constructor Detail

ScalarSynchronousSingleback to summary
protected ScalarSynchronousSingle(final T t)

Method Detail

createback to summary
public static <T> ScalarSynchronousSingle<T> create(T t)
getback to summary
public T get()
scalarFlatMapback to summary
public <R> Single<R> scalarFlatMap(final Func1<? super T, ? extends Single<? extends R>> func)
scalarScheduleOnback to summary
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:Scheduler

the target scheduler

Returns:Single<T>

the new observable

rx.internal.util back to summary

pack-priv final Class ScalarSynchronousSingle.DirectScheduledEmission<T>

extends Object
implements Single.OnSubscribe<T>
Class Inheritance
  • java.lang.Object
  • rx.internal.util.ScalarSynchronousSingle.DirectScheduledEmission
All Implemented Interfaces
rx.Single.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Optimized observeOn for scalar value observed on the EventLoopsScheduler.

Field Summary

Modifier and TypeField and Description
private final EventLoopsScheduler
es

private final T
value

Constructor Summary

AccessConstructor and Description
pack-priv
DirectScheduledEmission(EventLoopsScheduler es, T value)

Method Summary

Modifier and TypeMethod and Description
public void
call(SingleSubscriber<? super T> singleSubscriber)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

esback to summary
private final EventLoopsScheduler es
valueback to summary
private final T value

Constructor Detail

DirectScheduledEmissionback to summary
pack-priv DirectScheduledEmission(EventLoopsScheduler es, T value)

Method Detail

callback to summary
public void call(SingleSubscriber<? super T> singleSubscriber)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.util back to summary

pack-priv final Class ScalarSynchronousSingle.NormalScheduledEmission<T>

extends Object
implements Single.OnSubscribe<T>
Class Inheritance
  • java.lang.Object
  • rx.internal.util.ScalarSynchronousSingle.NormalScheduledEmission
All Implemented Interfaces
rx.Single.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Emits a scalar value on a general scheduler.

Field Summary

Modifier and TypeField and Description
private final Scheduler
scheduler

private final T
value

Constructor Summary

AccessConstructor and Description
pack-priv
NormalScheduledEmission(Scheduler scheduler, T value)

Method Summary

Modifier and TypeMethod and Description
public void
call(SingleSubscriber<? super T> singleSubscriber)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

schedulerback to summary
private final Scheduler scheduler
valueback to summary
private final T value

Constructor Detail

NormalScheduledEmissionback to summary
pack-priv NormalScheduledEmission(Scheduler scheduler, T value)

Method Detail

callback to summary
public void call(SingleSubscriber<? super T> singleSubscriber)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.util back to summary

pack-priv final Class ScalarSynchronousSingle.ScalarSynchronousSingleAction<T>

extends Object
implements Action0
Class Inheritance
  • java.lang.Object
  • rx.internal.util.ScalarSynchronousSingle.ScalarSynchronousSingleAction
All Implemented Interfaces
rx.functions.Action0, rx.functions.Action, rx.functions.Function
Action that emits a single value when called.

Field Summary

Modifier and TypeField and Description
private final SingleSubscriber<? super T>
subscriber

private final T
value

Constructor Summary

AccessConstructor and Description
pack-priv
ScalarSynchronousSingleAction(SingleSubscriber<? super T> subscriber, T value)

Method Summary

Modifier and TypeMethod and Description
public void
call()

Implements rx.functions.Action0.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

subscriberback to summary
private final SingleSubscriber<? super T> subscriber
valueback to summary
private final T value

Constructor Detail

ScalarSynchronousSingleActionback to summary
pack-priv ScalarSynchronousSingleAction(SingleSubscriber<? super T> subscriber, T value)

Method Detail

callback to summary
public void call()

Implements rx.functions.Action0.call.

Annotations
@Override