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); }