package e.v;

import e.s.c.k;
import java.util.Iterator;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes.dex */
public final class a<T> implements b<T> {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final AtomicReference<b<T>> f6042a;

    public a(b<? extends T> bVar) {
        k.e(bVar, "sequence");
        this.f6042a = new AtomicReference<>(bVar);
    }

    @Override // e.v.b
    public Iterator<T> iterator() {
        b<T> andSet = this.f6042a.getAndSet(null);
        if (andSet != null) {
            return andSet.iterator();
        }
        throw new IllegalStateException("This sequence can be consumed only once.");
    }
}