hu.akarnokd.reactive4java.util

Class RefCountObservable<T>

java.lang.Object

hu.akarnokd.reactive4java.util.Producer<T>

hu.akarnokd.reactive4java.util.RefCountObservable<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

Observable<T>

public class RefCountObservable<T>
extends Producer<T>

Observable which wraps an observable and manages a reference counting closeable.

Since:

0.97

Nested Class Summary

Nested classes/interfaces inherited from class hu.akarnokd.reactive4java.util.Producer

Producer.State<U>

Field Summary

Fields

Modifier and Type	Field and Description
protected RefCountCloseable	refCount The reference counter.
protected Observable<? extends T>	source The wrapped observable.

Constructor Summary

Constructors

Constructor and Description
RefCountObservable(Observable<? extends T> source, RefCountCloseable refCount) Constructor.

Method Summary

Modifier and Type	Method and Description
protected java.io.Closeable	run(Observer<? super T> observer, java.io.Closeable cancel, Action1<java.io.Closeable> setSink) The core implementation of the operator, called upon registration to the producer.

Methods inherited from class hu.akarnokd.reactive4java.util.Producer

register, registerRaw

Methods inherited from class java.lang.Object

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

Field Detail

source

protected final Observable<? extends T> source

The wrapped observable.

refCount

protected final RefCountCloseable refCount

The reference counter.

Constructor Detail

RefCountObservable

public RefCountObservable(Observable<? extends T> source,
                          RefCountCloseable refCount)

Constructor.

Parameters:

source - the source observable

refCount - the reference counting closeable

Method Detail

run

protected java.io.Closeable run(Observer<? super T> observer,
                                java.io.Closeable cancel,
                                Action1<java.io.Closeable> setSink)

Description copied from class: Producer

The core implementation of the operator, called upon registration to the producer.

Note that the observer is not automatically detached in case of error or finish cases. Implementations should ensure proper termination.

Specified by:

run in class Producer<T>

Parameters:

observer - the observer to send notifications on

cancel - the cancellation handler from the run() call, allows self cancellations

setSink - communicates the sink to the registering party which allows consumers to tunnel close calls into the sink, which can stop processing

Returns:

the closeable representing all resources and/or registrations to cancel at once.