22 lines
765 B
Java
22 lines
765 B
Java
|
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);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|