package 㴹.K.Ԕ.㿎;

import io.reactivex.internal.subscriptions.SubscriptionHelper;
import ඓ.ⁱ.K.ඓ.C1252;
import 㳳.ʬ.AbstractC2396;
import 㴹.K.Ԕ.ʬ.AbstractC2433;
import 㴹.K.Ԕ.ʬ.AbstractC2436;

/* renamed from: 㴹.K.Ԕ.㿎.K  reason: contains not printable characters */
/* compiled from: BasicFuseableConditionalSubscriber */
public abstract class AbstractC2490<T, R> implements AbstractC2436<T>, AbstractC2433<R> {

    /* renamed from: ʬ  reason: contains not printable characters */
    public AbstractC2396 f8492;

    /* renamed from: ඓ  reason: contains not printable characters */
    public boolean f8493;

    /* renamed from: ῲ  reason: contains not printable characters */
    public final AbstractC2436<? super R> f8494;

    /* renamed from: 㴹  reason: contains not printable characters */
    public int f8495;

    /* renamed from: 㸾  reason: contains not printable characters */
    public AbstractC2433<T> f8496;

    public AbstractC2490(AbstractC2436<? super R> k) {
        this.f8494 = k;
    }

    @Override // 㳳.ʬ.AbstractC2396
    public void cancel() {
        this.f8492.cancel();
    }

    @Override // 㴹.K.Ԕ.ʬ.AbstractC2439
    public void clear() {
        this.f8496.clear();
    }

    @Override // 㴹.K.Ԕ.ʬ.AbstractC2439
    public boolean isEmpty() {
        return this.f8496.isEmpty();
    }

    @Override // 㴹.K.Ԕ.ʬ.AbstractC2439
    public final boolean offer(R r) {
        throw new UnsupportedOperationException("Should not be called!");
    }

    @Override // 㳳.ʬ.AbstractC2397
    public void onComplete() {
        if (!this.f8493) {
            this.f8493 = true;
            this.f8494.onComplete();
        }
    }

    @Override // 㳳.ʬ.AbstractC2397
    public void onError(Throwable th) {
        if (this.f8493) {
            C1252.m3349(th);
            return;
        }
        this.f8493 = true;
        this.f8494.onError(th);
    }

    @Override // 㳳.ʬ.AbstractC2397, 㴹.K.AbstractC2431
    public final void onSubscribe(AbstractC2396 r2) {
        if (SubscriptionHelper.validate(this.f8492, r2)) {
            this.f8492 = r2;
            if (r2 instanceof AbstractC2433) {
                this.f8496 = (AbstractC2433) r2;
            }
            this.f8494.onSubscribe(this);
        }
    }

    @Override // 㳳.ʬ.AbstractC2396
    public void request(long j) {
        this.f8492.request(j);
    }
}
