OperatorConcat.java 文件源码

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