package 㴹.K;

import com.google.android.material.timepicker.RadialViewGroup;
import io.reactivex.internal.observers.LambdaObserver;
import io.reactivex.internal.operators.observable.ObservableBuffer;
import io.reactivex.internal.operators.observable.ObservableFlatMap;
import io.reactivex.internal.operators.observable.ObservableObserveOn;
import io.reactivex.internal.operators.observable.ObservableSubscribeOn;
import io.reactivex.internal.operators.observable.ObservableUnsubscribeOn;
import io.reactivex.internal.util.ArrayListSupplier;
import java.util.List;
import java.util.concurrent.Callable;
import ඓ.ⁱ.K.ඓ.C1252;
import 㴹.K.Ԕ.ʬ.AbstractCallableC2437;
import 㴹.K.Ԕ.ඓ.ῲ.C2442;
import 㴹.K.Ԕ.ඓ.ῲ.C2443;
import 㴹.K.Ԕ.ඓ.ῲ.C2444;
import 㴹.K.Ԕ.ඓ.ῲ.C2446;
import 㴹.K.Ԕ.ῲ.C2456;
import 㴹.K.Ԕ.ῲ.C2457;
import 㴹.K.㑃.AbstractC2514;
import 㴹.K.䁗.AbstractC2521;
import 㴹.K.䁗.AbstractC2522;
import 㴹.K.䁗.AbstractC2523;

/* renamed from: 㴹.K.ඓ  reason: contains not printable characters */
/* compiled from: Observable */
public abstract class AbstractC2500<T> implements AbstractC2518<T> {
    /* renamed from: ʬ  reason: contains not printable characters */
    public final AbstractC2500<T> m6537(AbstractC2508 r2) {
        C2456.m6500(r2, "scheduler is null");
        return C1252.m3345(new ObservableUnsubscribeOn(this, r2));
    }

    /* renamed from: ῲ  reason: contains not printable characters */
    public final AbstractC2500<T> m6538(AbstractC2508 r2) {
        C2456.m6500(r2, "scheduler is null");
        return C1252.m3345(new ObservableSubscribeOn(this, r2));
    }

    /* renamed from: ῲ  reason: contains not printable characters */
    public abstract void m6539(AbstractC2520<? super T> v);

    /* renamed from: K  reason: contains not printable characters */
    public final <R> AbstractC2500<R> m6543(AbstractC2521<? super T, ? extends AbstractC2518<? extends R>> r8, boolean z, int i) {
        int r5 = AbstractC2511.m6556();
        C2456.m6500(r8, "mapper is null");
        C2456.m6499(i, "maxConcurrency");
        C2456.m6499(r5, "bufferSize");
        if (!(this instanceof AbstractCallableC2437)) {
            return C1252.m3345(new ObservableFlatMap(this, r8, z, i, r5));
        }
        Object call = ((AbstractCallableC2437) this).call();
        if (call == null) {
            return m6535();
        }
        return C1252.m3345(new C2444(call, r8));
    }

    /* renamed from: K  reason: contains not printable characters */
    public final AbstractC2500<T> m6541(AbstractC2508 r4) {
        int r0 = AbstractC2511.m6556();
        C2456.m6500(r4, "scheduler is null");
        C2456.m6499(r0, "bufferSize");
        return C1252.m3345(new ObservableObserveOn(this, r4, false, r0));
    }

    /* renamed from: K  reason: contains not printable characters */
    public static <T> AbstractC2500<T> m6535() {
        return C1252.m3345(C2443.f8385);
    }

    /* renamed from: K  reason: contains not printable characters */
    public static <T> AbstractC2500<T> m6536(T t) {
        C2456.m6500(t, "The item is null");
        return C1252.m3345((AbstractC2500) new C2446(t));
    }

    /* renamed from: K  reason: contains not printable characters */
    public final AbstractC2500<List<T>> m6540(int i) {
        Callable asCallable = ArrayListSupplier.asCallable();
        C2456.m6499(i, "count");
        C2456.m6499(i, RadialViewGroup.SKIP_TAG);
        C2456.m6500(asCallable, "bufferSupplier is null");
        return C1252.m3345(new ObservableBuffer(this, i, i, asCallable));
    }

    /* renamed from: K  reason: contains not printable characters */
    public final <R> AbstractC2500<R> m6542(AbstractC2512<? super T, ? extends R> r2) {
        C2456.m6500(r2, "composer is null");
        AbstractC2518<? extends R> r22 = r2.m6563(this);
        C2456.m6500(r22, "source is null");
        if (r22 instanceof AbstractC2500) {
            return C1252.m3345((AbstractC2500) r22);
        }
        return C1252.m3345(new C2442(r22));
    }

    /* renamed from: K  reason: contains not printable characters */
    public final AbstractC2514 m6544(AbstractC2522<? super T> r5) {
        AbstractC2522<Throwable> r0 = C2457.f8412;
        AbstractC2523 k = C2457.f8411;
        AbstractC2522<Object> r2 = C2457.f8415;
        C2456.m6500(r5, "onNext is null");
        C2456.m6500(r0, "onError is null");
        C2456.m6500(k, "onComplete is null");
        C2456.m6500(r2, "onSubscribe is null");
        LambdaObserver lambdaObserver = new LambdaObserver(r5, r0, k, r2);
        m6545((AbstractC2520) lambdaObserver);
        return lambdaObserver;
    }

    /* renamed from: K  reason: contains not printable characters */
    public final void m6545(AbstractC2520<? super T> r3) {
        C2456.m6500(r3, "observer is null");
        try {
            C2456.m6500(r3, "Plugin returned null Observer");
            m6539(r3);
        } catch (NullPointerException e) {
            throw e;
        } catch (Throwable th) {
            C1252.m3329(th);
            C1252.m3349(th);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }
}
