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 Single

Resource - 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

Constructor Summary

Constructors

Constructor	Description
SingleOnSubscribeUsing(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Single<? extends T>> observableFactory, Action1<? super Resource> disposeAction, boolean disposeEagerly)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

resourceFactory

final Func0<Resource> resourceFactory

singleFactory

final Func1<? super Resource,? extends Single<? extends T>> singleFactory

disposeAction

final Action1<? super Resource> disposeAction

disposeEagerly

final boolean disposeEagerly

Constructor Detail

SingleOnSubscribeUsing

public SingleOnSubscribeUsing(Func0<Resource> resourceFactory,
                              Func1<? super Resource,? extends Single<? extends T>> observableFactory,
                              Action1<? super Resource> disposeAction,
                              boolean disposeEagerly)

Method Detail

call

public void call(SingleSubscriber<? super T> child)

Specified by:

call in interface Action1<T>

handleSubscriptionTimeError

void handleSubscriptionTimeError(SingleSubscriber<? super T> t,
                                 Resource resource,
                                 java.lang.Throwable ex)