package 㴹.K;

import io.reactivex.internal.operators.flowable.FlowableInternalHelper$RequestMax;
import io.reactivex.internal.operators.flowable.FlowableObserveOn;
import io.reactivex.internal.subscribers.LambdaSubscriber;
import ඓ.ⁱ.K.ඓ.C1252;
import 㳳.ʬ.AbstractC2397;
import 㳳.ʬ.AbstractC2398;
import 㴹.K.Ԕ.ඓ.K.C2449;
import 㴹.K.Ԕ.ඓ.K.C2452;
import 㴹.K.Ԕ.ῲ.C2456;
import 㴹.K.Ԕ.ῲ.C2457;
import 㴹.K.㑃.AbstractC2514;
import 㴹.K.䁗.AbstractC2521;
import 㴹.K.䁗.AbstractC2522;
import 㴹.K.䁗.AbstractC2523;

/* renamed from: 㴹.K.ῲ  reason: contains not printable characters */
/* compiled from: Flowable */
public abstract class AbstractC2511<T> implements AbstractC2398<T> {

    /* renamed from: ῲ  reason: contains not printable characters */
    public static final int f8514 = Math.max(1, Integer.getInteger("rx2.buffer-size", 128).intValue());

    /* renamed from: ῲ  reason: contains not printable characters */
    public static int m6556() {
        return f8514;
    }

    /* renamed from: K  reason: contains not printable characters */
    public final AbstractC2514 m6560() {
        AbstractC2522<Object> r0 = C2457.f8415;
        AbstractC2522<Throwable> r1 = C2457.f8412;
        AbstractC2523 k = C2457.f8411;
        FlowableInternalHelper$RequestMax flowableInternalHelper$RequestMax = FlowableInternalHelper$RequestMax.INSTANCE;
        C2456.m6500(r0, "onNext is null");
        C2456.m6500(r1, "onError is null");
        C2456.m6500(k, "onComplete is null");
        C2456.m6500(flowableInternalHelper$RequestMax, "onSubscribe is null");
        LambdaSubscriber lambdaSubscriber = new LambdaSubscriber(r0, r1, k, flowableInternalHelper$RequestMax);
        m6562((AbstractC2431) lambdaSubscriber);
        return lambdaSubscriber;
    }

    /* renamed from: K  reason: contains not printable characters */
    public abstract void m6561(AbstractC2397<? super T> v);

    /* renamed from: K  reason: contains not printable characters */
    public final AbstractC2511<T> m6558(AbstractC2508 r4) {
        int i = f8514;
        C2456.m6500(r4, "scheduler is null");
        C2456.m6499(i, "bufferSize");
        return C1252.m3348(new FlowableObserveOn(this, r4, false, i));
    }

    /* renamed from: K  reason: contains not printable characters */
    public static <T> AbstractC2511<T> m6557(T t) {
        C2456.m6500(t, "item is null");
        return C1252.m3348((AbstractC2511) new C2452(t));
    }

    /* renamed from: K  reason: contains not printable characters */
    public final <R> AbstractC2511<R> m6559(AbstractC2521<? super T, ? extends R> r2) {
        C2456.m6500(r2, "mapper is null");
        return C1252.m3348(new C2449(this, r2));
    }

    /* renamed from: K  reason: contains not printable characters */
    public final void m6562(AbstractC2431<? super T> r3) {
        C2456.m6500(r3, "s is null");
        try {
            C2456.m6500(r3, "Plugin returned null Subscriber");
            m6561((AbstractC2397) 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;
        }
    }
}
