package kotlinx.coroutines; import kotlin.Unit; import kotlin.coroutines.Continuation; import kotlin.coroutines.CoroutineContext; import kotlin.coroutines.intrinsics.IntrinsicsKt__IntrinsicsJvmKt; import kotlin.coroutines.intrinsics.IntrinsicsKt__IntrinsicsKt; import kotlin.coroutines.jvm.internal.DebugProbesKt; import kotlinx.coroutines.internal.DispatchedContinuation; import kotlinx.coroutines.internal.DispatchedContinuationKt; /* loaded from: classes5.dex */ public abstract class YieldKt { public static final Object yield(Continuation continuation) { Continuation intercepted; Object coroutine_suspended; Object coroutine_suspended2; Object coroutine_suspended3; CoroutineContext context = continuation.getContext(); JobKt.ensureActive(context); intercepted = IntrinsicsKt__IntrinsicsJvmKt.intercepted(continuation); DispatchedContinuation dispatchedContinuation = intercepted instanceof DispatchedContinuation ? (DispatchedContinuation) intercepted : null; if (dispatchedContinuation == null) { coroutine_suspended = Unit.INSTANCE; } else { if (dispatchedContinuation.dispatcher.isDispatchNeeded(context)) { dispatchedContinuation.dispatchYield$kotlinx_coroutines_core(context, Unit.INSTANCE); } else { YieldContext yieldContext = new YieldContext(); CoroutineContext plus = context.plus(yieldContext); Unit unit = Unit.INSTANCE; dispatchedContinuation.dispatchYield$kotlinx_coroutines_core(plus, unit); if (yieldContext.dispatcherWasUnconfined) { coroutine_suspended = DispatchedContinuationKt.yieldUndispatched(dispatchedContinuation) ? IntrinsicsKt__IntrinsicsKt.getCOROUTINE_SUSPENDED() : unit; } } coroutine_suspended = IntrinsicsKt__IntrinsicsKt.getCOROUTINE_SUSPENDED(); } coroutine_suspended2 = IntrinsicsKt__IntrinsicsKt.getCOROUTINE_SUSPENDED(); if (coroutine_suspended == coroutine_suspended2) { DebugProbesKt.probeCoroutineSuspended(continuation); } coroutine_suspended3 = IntrinsicsKt__IntrinsicsKt.getCOROUTINE_SUSPENDED(); return coroutine_suspended == coroutine_suspended3 ? coroutine_suspended : Unit.INSTANCE; } }