OperatorConcat.java 文件源码

@Override
public Subscriber<? super Observable<? extends T>> call(final Subscriber<? super T> child) {
    final SerializedSubscriber<T> s = new SerializedSubscriber<T>(child);
    final SerialSubscription current = new SerialSubscription();
    child.add(current);
    ConcatSubscriber<T> cs = new ConcatSubscriber<T>(s, current);
    ConcatProducer<T> cp = new ConcatProducer<T>(cs);
    child.setProducer(cp);
    return cs;
}