Package rx.internal.util
Class ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T>
java.lang.Object
rx.internal.util.ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
- Enclosing class:
ScalarSynchronousObservable<T>
static final class ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T>
extends Object
implements Observable.OnSubscribe<T>
The OnSubscribe implementation that creates the ScalarAsyncProducer for each
incoming subscriber.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Func1
<Action0, Subscription> (package private) final T
-
Constructor Summary
Constructors -
Method Summary