OnSubscribeGroupJoin.java 文件源码

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