Top Description Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeRefCount<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the value type
Imports
java.util.concurrent.atomic.*, java.util.concurrent.locks.ReentrantLock, rx.*, .Observable.OnSubscribe, rx.functions.*, rx.observables.ConnectableObservable, rx.subscriptions.*
Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.

Field Summary

Modifier and TypeField and Description
pack-priv volatile CompositeSubscription
baseSubscription

pack-priv final ReentrantLock
lock

Use this lock for every subscription and disconnect action.

private final ConnectableObservable<? extends T>
source

pack-priv final AtomicInteger
subscriptionCount

Constructor Summary

AccessConstructor and Description
public
OnSubscribeRefCount(ConnectableObservable<? extends T>
observable to apply ref count to
source)

Constructor.

Method Summary

Modifier and TypeMethod and Description
public void
call(final Subscriber<? super T> subscriber)

Implements rx.functions.Action1.call.

private Subscription
disconnect(final CompositeSubscription current)

pack-priv void
doSubscribe(final Subscriber<? super T> subscriber, final CompositeSubscription currentBase)

private Action1<Subscription>
onSubscribe(final Subscriber<? super T> subscriber, final AtomicBoolean writeLocked)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

baseSubscriptionback to summary
pack-priv volatile CompositeSubscription baseSubscription
lockback to summary
pack-priv final ReentrantLock lock

Use this lock for every subscription and disconnect action.

sourceback to summary
private final ConnectableObservable<? extends T> source
subscriptionCountback to summary
pack-priv final AtomicInteger subscriptionCount

Constructor Detail

OnSubscribeRefCountback to summary
public OnSubscribeRefCount(ConnectableObservable<? extends T> source)

Constructor.

Parameters
source:ConnectableObservable<? extends T>

observable to apply ref count to

Method Detail

callback to summary
public void call(final Subscriber<? super T> subscriber)

Implements rx.functions.Action1.call.

Annotations
@Override
disconnectback to summary
private Subscription disconnect(final CompositeSubscription current)
doSubscribeback to summary
pack-priv void doSubscribe(final Subscriber<? super T> subscriber, final CompositeSubscription currentBase)
onSubscribeback to summary
private Action1<Subscription> onSubscribe(final Subscriber<? super T> subscriber, final AtomicBoolean writeLocked)