Package rx.internal.operators
Class SingleOnSubscribeUsing<T,Resource>
- java.lang.Object
-
- rx.internal.operators.SingleOnSubscribeUsing<T,Resource>
-
- Type Parameters:
T
- the value type of the SingleResource
- the resource type
- All Implemented Interfaces:
Action
,Action1<SingleSubscriber<? super T>>
,Function
,Single.OnSubscribe<T>
public final class SingleOnSubscribeUsing<T,Resource> extends java.lang.Object implements Single.OnSubscribe<T>
Generates a resource, derives a Single from it and disposes that resource once the Single terminates.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Action1<? super Resource>
disposeAction
(package private) boolean
disposeEagerly
(package private) Func0<Resource>
resourceFactory
(package private) Func1<? super Resource,? extends Single<? extends T>>
singleFactory
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
call(SingleSubscriber<? super T> child)
(package private) void
handleSubscriptionTimeError(SingleSubscriber<? super T> t, Resource resource, java.lang.Throwable ex)
-
-
-
Method Detail
-
call
public void call(SingleSubscriber<? super T> child)
-
handleSubscriptionTimeError
void handleSubscriptionTimeError(SingleSubscriber<? super T> t, Resource resource, java.lang.Throwable ex)
-
-