package o;

import java.util.concurrent.atomic.AtomicInteger;

/* loaded from: classes6.dex */
public final class fYQ {
    /* JADX WARN: Multi-variable type inference failed */
    public static <T> void b(InterfaceC13174fSv<? super T> interfaceC13174fSv, T t, AtomicInteger atomicInteger, C13355fYI c13355fYI) {
        if (atomicInteger.get() == 0 && atomicInteger.compareAndSet(0, 1)) {
            interfaceC13174fSv.onNext(t);
            if (atomicInteger.decrementAndGet() != 0) {
                Throwable b = fYR.b(c13355fYI);
                if (b == null) {
                    interfaceC13174fSv.onComplete();
                } else if (b != fYR.b) {
                    interfaceC13174fSv.onError(b);
                }
            }
        }
    }
}