OperatorConcat.java 文件源码

public ConcatSubscriber(Subscriber<T> s, SerialSubscription current) {
    super(s);
    this.child = s;
    this.current = current;
    this.arbiter = new ProducerArbiter();
    this.queue = new ConcurrentLinkedQueue();
    add(Subscriptions.create(new Action0() {
        public void call() {
            ConcatSubscriber.this.queue.clear();
        }
    }));
}