hu.akarnokd.reactive4java.reactive

Class RefCount<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.RefCount<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

Observable<T>

public class RefCount<T>
extends java.lang.Object
implements Observable<T>

Returns an observable sequence which connects to the source for the first registered party and stays connected to the source as long as there is at least one registered party to it.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.Closeable	connection The active connection.
protected int	count The registration count.
protected java.util.concurrent.locks.Lock	lock The lock.
protected ConnectableObservable<? extends T>	source The source .

Constructor Summary

Constructors

Constructor and Description
RefCount(ConnectableObservable<? extends T> source) Constructor with a default fair reentrant lock.
RefCount(ConnectableObservable<? extends T> source, java.util.concurrent.locks.Lock lock) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super T> observer) Registers an observer for the notification of Ts.

Methods inherited from class java.lang.Object

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

Field Detail

lock

@Nonnull
protected final java.util.concurrent.locks.Lock lock

The lock.

source

@Nonnull
protected final ConnectableObservable<? extends T> source

The source .

connection

protected java.io.Closeable connection

The active connection.

count

protected int count

The registration count.

Constructor Detail

RefCount

public RefCount(ConnectableObservable<? extends T> source)

Constructor with a default fair reentrant lock.

Parameters:

source - the source of Ts

RefCount

public RefCount(ConnectableObservable<? extends T> source,
                java.util.concurrent.locks.Lock lock)

Constructor.

Parameters:

source - the source of Ts

lock - the lock

Method Detail

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            Observer<? super T> observer)

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<T>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider