Package rx.internal.util
Class ScalarSynchronousSingle.DirectScheduledEmission<T>
java.lang.Object
rx.internal.util.ScalarSynchronousSingle.DirectScheduledEmission<T>
- All Implemented Interfaces:
Action
,Action1<SingleSubscriber<? super T>>
,Function
,Single.OnSubscribe<T>
- Enclosing class:
ScalarSynchronousSingle<T>
static final class ScalarSynchronousSingle.DirectScheduledEmission<T>
extends Object
implements Single.OnSubscribe<T>
Optimized observeOn for scalar value observed on the EventLoopsScheduler.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
es
-
value
-
-
Constructor Details
-
DirectScheduledEmission
DirectScheduledEmission(EventLoopsScheduler es, T value)
-
-
Method Details