Java 类io.reactivex.internal.fuseable.SimpleQueue 实例源码

void clearSources() {
    Arrays.fill(latest, this);
    for (InnerQueuedSubscriber<T> d : subscribers) {
        SimpleQueue<T> q = d.queue();
        if (q != null) {
            q.clear();
        }
    }
}

void cancelAndClearSources() {
    Arrays.fill(latest, this);
    for (InnerQueuedSubscriber<T> d : subscribers) {
        d.cancel();
        SimpleQueue<T> q = d.queue();
        if (q != null) {
            q.clear();
        }
    }
}

@Override
public void innerNext(FlatMapInnerSubscriber<T, R> inner, R item) {
    SimpleQueue<R> q = inner.queue();
    q.offer(item);
    drain();
}