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.