package kotlinx.coroutines.flow;

import kotlin.coroutines.Continuation;

/* JADX INFO: loaded from: classes.dex */
public final class t extends kotlinx.coroutines.flow.internal.c {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public long f29426a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public kotlinx.coroutines.h f29427b;

    @Override // kotlinx.coroutines.flow.internal.c
    public final boolean a(kotlinx.coroutines.flow.internal.a aVar) {
        s sVar = (s) aVar;
        if (this.f29426a >= 0) {
            return false;
        }
        long j10 = sVar.f29422h;
        if (j10 < sVar.f29423i) {
            sVar.f29423i = j10;
        }
        this.f29426a = j10;
        return true;
    }

    @Override // kotlinx.coroutines.flow.internal.c
    public final Continuation[] b(kotlinx.coroutines.flow.internal.a aVar) {
        long j10 = this.f29426a;
        this.f29426a = -1L;
        this.f29427b = null;
        return ((s) aVar).t(j10);
    }
}