Java 类rx.subscriptions.RefCountSubscription 实例源码

public ResultManager(Subscriber<? super R> subscriber) {
    this.subscriber = subscriber;
    this.group = new CompositeSubscription();
    this.cancel = new RefCountSubscription(this.group);
}

public WindowObservableFunc(Observable<T> underlying, RefCountSubscription refCount) {
    this.refCount = refCount;
    this.underlying = underlying;
}

public ResultManager(Subscriber<? super R> subscriber) {
    this.subscriber = subscriber;
    this.group = new CompositeSubscription();
    this.cancel = new RefCountSubscription(group);
}

public WindowObservableFunc(Observable<T> underlying, RefCountSubscription refCount) {
    this.refCount = refCount;
    this.underlying = underlying;
}

public ResultManager(Subscriber<? super R> subscriber) {
    this.subscriber = subscriber;
    this.group = new CompositeSubscription();
    this.cancel = new RefCountSubscription(group);
}

public WindowObservableFunc(Observable<T> underlying, RefCountSubscription refCount) {
    this.refCount = refCount;
    this.underlying = underlying;
}