package o;

import java.util.Objects;

/* renamed from: o.fZa, reason: case insensitive filesystem */
/* loaded from: classes6.dex */
public abstract class AbstractC13398fZa<T> implements InterfaceC13174fSv<T> {
    private fSJ e;

    @Override // o.InterfaceC13174fSv
    public final void onSubscribe(fSJ fsj) {
        fSJ fsj2 = this.e;
        Class<?> cls = getClass();
        Objects.requireNonNull(fsj, "next is null");
        if (fsj2 == null) {
            this.e = fsj;
            return;
        }
        fsj.dispose();
        if (fsj2 != EnumC13192fTf.DISPOSED) {
            C13356fYM.b(cls);
        }
    }
}