46 lines
1.6 KiB
Java
46 lines
1.6 KiB
Java
package io.reactivex.internal.util;
|
|
|
|
import io.reactivex.disposables.Disposable;
|
|
import io.reactivex.exceptions.ProtocolViolationException;
|
|
import io.reactivex.internal.disposables.DisposableHelper;
|
|
import io.reactivex.internal.functions.ObjectHelper;
|
|
import io.reactivex.plugins.RxJavaPlugins;
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
|
/* loaded from: classes2.dex */
|
|
public final class EndConsumerHelper {
|
|
public static boolean a(Disposable disposable, Disposable disposable2, Class<?> cls) {
|
|
ObjectHelper.a(disposable2, "next is null");
|
|
if (disposable == null) {
|
|
return true;
|
|
}
|
|
disposable2.dispose();
|
|
if (disposable == DisposableHelper.DISPOSED) {
|
|
return false;
|
|
}
|
|
a(cls);
|
|
return false;
|
|
}
|
|
|
|
public static boolean a(AtomicReference<Disposable> atomicReference, Disposable disposable, Class<?> cls) {
|
|
ObjectHelper.a(disposable, "next is null");
|
|
if (atomicReference.compareAndSet(null, disposable)) {
|
|
return true;
|
|
}
|
|
disposable.dispose();
|
|
if (atomicReference.get() == DisposableHelper.DISPOSED) {
|
|
return false;
|
|
}
|
|
a(cls);
|
|
return false;
|
|
}
|
|
|
|
public static String a(String str) {
|
|
return "It is not allowed to subscribe with a(n) " + str + " multiple times. Please create a fresh instance of " + str + " and subscribe that to the target source instead.";
|
|
}
|
|
|
|
public static void a(Class<?> cls) {
|
|
RxJavaPlugins.b(new ProtocolViolationException(a(cls.getName())));
|
|
}
|
|
}
|