Top Description Fields Constructors Methods
rx.internal.operators

public final Class SingleOnSubscribeUsing<T, Resource>

extends Object
implements Single.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Single.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the value type of the Single
<Resource>
the resource type
Imports
java.util.Arrays, rx.*, rx.exceptions.*, rx.functions.*, rx.plugins.RxJavaHooks
Generates a resource, derives a Single from it and disposes that resource once the Single terminates.

Field Summary

Modifier and TypeField and Description
pack-priv final Action1<? super Resource>
disposeAction

pack-priv final boolean
disposeEagerly

pack-priv final Func0<Resource>
resourceFactory

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

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
public void
call(final SingleSubscriber<? super T> child)

Implements rx.functions.Action1.call.

pack-priv void
handleSubscriptionTimeError(SingleSubscriber<? super T> t, Resource resource, Throwable ex)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

disposeActionback to summary
pack-priv final Action1<? super Resource> disposeAction
disposeEagerlyback to summary
pack-priv final boolean disposeEagerly
resourceFactoryback to summary
pack-priv final Func0<Resource> resourceFactory
singleFactoryback to summary
pack-priv final Func1<? super Resource, ? extends Single<? extends T>> singleFactory

Constructor Detail

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

Method Detail

callback to summary
public void call(final SingleSubscriber<? super T> child)

Implements rx.functions.Action1.call.

Annotations
@Override
handleSubscriptionTimeErrorback to summary
pack-priv void handleSubscriptionTimeError(SingleSubscriber<? super T> t, Resource resource, Throwable ex)