package kotlinx.coroutines.flow.internal;

import java.util.ArrayList;
import kotlin.collections.n;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.EmptyCoroutineContext;
import kotlin.coroutines.intrinsics.CoroutineSingletons;
import kotlinx.coroutines.channels.BufferOverflow;
import kotlinx.coroutines.internal.r;
import kotlinx.coroutines.y;

/* JADX INFO: loaded from: classes.dex */
public abstract class d implements h {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final kotlin.coroutines.h f29386a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final int f29387b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final BufferOverflow f29388c;

    public d(kotlin.coroutines.h hVar, int i10, BufferOverflow bufferOverflow) {
        this.f29386a = hVar;
        this.f29387b = i10;
        this.f29388c = bufferOverflow;
    }

    @Override // kotlinx.coroutines.flow.f
    public Object a(kotlinx.coroutines.flow.g gVar, Continuation continuation) throws Throwable {
        ChannelFlow$collect$2 channelFlow$collect$2 = new ChannelFlow$collect$2(null, gVar, this);
        r rVar = new r(continuation, continuation.getContext());
        Object objC0 = y.c0(rVar, rVar, channelFlow$collect$2);
        return objC0 == CoroutineSingletons.f29226a ? objC0 : kd.e.f29109a;
    }

    /* JADX WARN: Removed duplicated region for block: B:9:0x0015  */
    @Override // kotlinx.coroutines.flow.internal.h
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final kotlinx.coroutines.flow.f b(kotlin.coroutines.h hVar, int i10, BufferOverflow bufferOverflow) {
        kotlin.coroutines.h hVar2 = this.f29386a;
        kotlin.coroutines.h hVarP = hVar.p(hVar2);
        BufferOverflow bufferOverflow2 = BufferOverflow.f29297a;
        BufferOverflow bufferOverflow3 = this.f29388c;
        int i11 = this.f29387b;
        if (bufferOverflow == bufferOverflow2) {
            if (i11 != -3) {
                if (i10 != -3) {
                    if (i11 != -2) {
                        if (i10 == -2) {
                            i10 = i11;
                        } else {
                            i10 += i11;
                            if (i10 < 0) {
                                i10 = Integer.MAX_VALUE;
                            }
                        }
                    }
                }
            }
            bufferOverflow = bufferOverflow3;
        }
        return (nb.g.c(hVarP, hVar2) && i10 == i11 && bufferOverflow == bufferOverflow3) ? this : d(hVarP, i10, bufferOverflow);
    }

    public abstract Object c(kotlinx.coroutines.channels.l lVar, Continuation continuation);

    public abstract d d(kotlin.coroutines.h hVar, int i10, BufferOverflow bufferOverflow);

    public String toString() {
        ArrayList arrayList = new ArrayList(4);
        EmptyCoroutineContext emptyCoroutineContext = EmptyCoroutineContext.f29221a;
        kotlin.coroutines.h hVar = this.f29386a;
        if (hVar != emptyCoroutineContext) {
            arrayList.add("context=" + hVar);
        }
        int i10 = this.f29387b;
        if (i10 != -3) {
            arrayList.add("capacity=" + i10);
        }
        BufferOverflow bufferOverflow = BufferOverflow.f29297a;
        BufferOverflow bufferOverflow2 = this.f29388c;
        if (bufferOverflow2 != bufferOverflow) {
            arrayList.add("onBufferOverflow=" + bufferOverflow2);
        }
        return getClass().getSimpleName() + '[' + n.j1(arrayList, ", ", null, null, null, 62) + ']';
    }
}