package androidx.compose.runtime;

import V4.C0772m;
import V4.InterfaceC0770l;
import a.AbstractC0872a;
import androidx.compose.runtime.BroadcastFrameClock;
import androidx.compose.runtime.MonotonicFrameClock;
import androidx.compose.runtime.internal.AwaiterQueue;
import androidx.compose.runtime.internal.StabilityInferred;
import java.util.concurrent.CancellationException;
import m3.AbstractC2467b;
import w4.C3137A;

/* JADX INFO: loaded from: classes.dex */
@StabilityInferred(parameters = 0)
public final class BroadcastFrameClock implements MonotonicFrameClock {
    public static final int $stable = 8;
    private final J4.a onNewAwaiters;
    private final AwaiterQueue<FrameAwaiter<?>> queue;

    public static final class FrameAwaiter<R> extends AwaiterQueue.Awaiter {
        private InterfaceC0770l continuation;
        private J4.c onFrame;

        public FrameAwaiter(J4.c cVar, InterfaceC0770l interfaceC0770l) {
            this.continuation = interfaceC0770l;
            this.onFrame = cVar;
        }

        @Override // androidx.compose.runtime.internal.AwaiterQueue.Awaiter
        public void cancel() {
            this.onFrame = null;
            this.continuation = null;
        }

        public final void resume(long j4) {
            InterfaceC0770l interfaceC0770l;
            Object objD;
            J4.c cVar = this.onFrame;
            if (cVar == null || (interfaceC0770l = this.continuation) == null) {
                return;
            }
            try {
                objD = cVar.invoke(Long.valueOf(j4));
            } catch (Throwable th) {
                objD = AbstractC2467b.d(th);
            }
            interfaceC0770l.resumeWith(objD);
        }

        @Override // androidx.compose.runtime.internal.AwaiterQueue.Awaiter
        public void resumeWithException(Throwable th) {
            InterfaceC0770l interfaceC0770l = this.continuation;
            if (interfaceC0770l != null) {
                interfaceC0770l.resumeWith(AbstractC2467b.d(th));
            }
        }
    }

    /* JADX WARN: Multi-variable type inference failed */
    public BroadcastFrameClock() {
        this(null, 1, 0 == true ? 1 : 0);
    }

    public static /* synthetic */ void cancel$default(BroadcastFrameClock broadcastFrameClock, CancellationException cancellationException, int i6, Object obj) {
        if ((i6 & 1) != 0) {
            cancellationException = new CancellationException("clock cancelled");
        }
        broadcastFrameClock.cancel(cancellationException);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final C3137A sendFrame$lambda$0(long j4, FrameAwaiter frameAwaiter) {
        frameAwaiter.resume(j4);
        return C3137A.f25453a;
    }

    public final void cancel(CancellationException cancellationException) {
        this.queue.fail(cancellationException);
    }

    @Override // androidx.compose.runtime.MonotonicFrameClock, A4.j
    public /* bridge */ <R> R fold(R r5, J4.e eVar) {
        return (R) MonotonicFrameClock.DefaultImpls.fold(this, r5, eVar);
    }

    @Override // androidx.compose.runtime.MonotonicFrameClock, A4.j
    public /* bridge */ <E extends A4.h> E get(A4.i iVar) {
        return (E) MonotonicFrameClock.DefaultImpls.get(this, iVar);
    }

    public final boolean getHasAwaiters() {
        return this.queue.getHasAwaiters();
    }

    @Override // androidx.compose.runtime.MonotonicFrameClock, A4.j
    public /* bridge */ A4.j minusKey(A4.i iVar) {
        return MonotonicFrameClock.DefaultImpls.minusKey(this, iVar);
    }

    @Override // androidx.compose.runtime.MonotonicFrameClock, A4.j
    public /* bridge */ A4.j plus(A4.j jVar) {
        return MonotonicFrameClock.DefaultImpls.plus(this, jVar);
    }

    public final void sendFrame(final long j4) {
        this.queue.flushAndDispatchAwaiters(new J4.c() { // from class: androidx.compose.runtime.b
            @Override // J4.c
            public final Object invoke(Object obj) {
                return BroadcastFrameClock.sendFrame$lambda$0(j4, (BroadcastFrameClock.FrameAwaiter) obj);
            }
        });
    }

    @Override // androidx.compose.runtime.MonotonicFrameClock
    public <R> Object withFrameNanos(J4.c cVar, A4.d dVar) {
        C0772m c0772m = new C0772m(1, AbstractC0872a.V(dVar));
        c0772m.s();
        final CancellationHandle cancellationHandleAddAwaiter = this.queue.addAwaiter(new FrameAwaiter(cVar, c0772m), this.onNewAwaiters);
        c0772m.u(new J4.c() { // from class: androidx.compose.runtime.BroadcastFrameClock$withFrameNanos$2$1
            @Override // J4.c
            public /* bridge */ /* synthetic */ Object invoke(Object obj) {
                invoke((Throwable) obj);
                return C3137A.f25453a;
            }

            public final void invoke(Throwable th) {
                cancellationHandleAddAwaiter.cancel();
            }
        });
        Object objR = c0772m.r();
        B4.a aVar = B4.a.f492a;
        return objR;
    }

    public BroadcastFrameClock(J4.a aVar) {
        this.onNewAwaiters = aVar;
        this.queue = new AwaiterQueue<>();
    }

    public /* synthetic */ BroadcastFrameClock(J4.a aVar, int i6, kotlin.jvm.internal.h hVar) {
        this((i6 & 1) != 0 ? null : aVar);
    }
}