Package rx.internal.operators
Class OnSubscribeUsing<T,Resource>
java.lang.Object
rx.internal.operators.OnSubscribeUsing<T,Resource>
- Type Parameters:
T
- the output value typeResource
- the resource type
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
Constructs an observable sequence that depends on a resource object.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final boolean
private final Func1
<? super Resource, ? extends Observable<? extends T>> -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeUsing
(Func0<Resource> resourceFactory, Func1<? super Resource, ? extends Observable<? extends T>> observableFactory, Action1<? super Resource> dispose, boolean disposeEagerly) -
Method Summary