package 㴹.K.Ԕ.㿎;

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

/* renamed from: 㴹.K.Ԕ.㿎.ῲ  reason: contains not printable characters */
/* compiled from: BasicFuseableSubscriber */
public abstract class AbstractC2489<T, R> implements AbstractC2431<T>, AbstractC2433<R> {

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

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

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

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

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

    public AbstractC2489(AbstractC2397<? super R> r1) {
        this.f8489 = r1;
    }

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

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

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

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

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

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

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

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