package e.a;

import com.seewo.adbcommons.model.base.ICmdMsg;

/* JADX WARN: Unexpected interfaces in signature: [java.lang.Object<T>] */
/* JADX INFO: compiled from: Flowable.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class e<T> {
    static final int a = Math.max(16, Integer.getInteger("rx2.buffer-size", ICmdMsg.ACTION_START_ACTIVITY).intValue());

    public static int a() {
        return a;
    }

    public final e<T> b() {
        return c(a(), false, true);
    }

    public final e<T> c(int i2, boolean z, boolean z2) {
        e.a.u.b.b.e(i2, "bufferSize");
        return e.a.w.a.k(new e.a.u.e.a.c(this, i2, z2, z, e.a.u.b.a.f3641b));
    }

    public final e<T> d() {
        return e.a.w.a.k(new e.a.u.e.a.d(this));
    }

    public final e<T> e() {
        return e.a.w.a.k(new e.a.u.e.a.f(this));
    }
}
