Daniel Elliott
c080f0d97f
- Added realracing3-community.apk (71.57 MB) - Removed 32-bit support (armeabi-v7a) - Only includes arm64-v8a libraries - Decompiled source code included - Added README-community.md with analysis
70 lines
3.0 KiB
Java
70 lines
3.0 KiB
Java
package kotlinx.coroutines;
|
|
|
|
import java.util.concurrent.CancellationException;
|
|
import kotlin.coroutines.Continuation;
|
|
import kotlin.coroutines.CoroutineContext;
|
|
import kotlin.coroutines.intrinsics.IntrinsicsKt__IntrinsicsKt;
|
|
import kotlin.coroutines.jvm.internal.DebugProbesKt;
|
|
import kotlin.jvm.functions.Function2;
|
|
import kotlinx.coroutines.internal.ContextScope;
|
|
import kotlinx.coroutines.internal.ScopeCoroutine;
|
|
import kotlinx.coroutines.intrinsics.UndispatchedKt;
|
|
|
|
/* loaded from: classes5.dex */
|
|
public abstract class CoroutineScopeKt {
|
|
public static final CoroutineScope plus(CoroutineScope coroutineScope, CoroutineContext coroutineContext) {
|
|
return new ContextScope(coroutineScope.getCoroutineContext().plus(coroutineContext));
|
|
}
|
|
|
|
public static final CoroutineScope MainScope() {
|
|
return new ContextScope(SupervisorKt.SupervisorJob$default(null, 1, null).plus(Dispatchers.getMain()));
|
|
}
|
|
|
|
public static final boolean isActive(CoroutineScope coroutineScope) {
|
|
Job job = (Job) coroutineScope.getCoroutineContext().get(Job.Key);
|
|
if (job != null) {
|
|
return job.isActive();
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public static final Object coroutineScope(Function2 function2, Continuation continuation) {
|
|
Object coroutine_suspended;
|
|
ScopeCoroutine scopeCoroutine = new ScopeCoroutine(continuation.getContext(), continuation);
|
|
Object startUndispatchedOrReturn = UndispatchedKt.startUndispatchedOrReturn(scopeCoroutine, scopeCoroutine, function2);
|
|
coroutine_suspended = IntrinsicsKt__IntrinsicsKt.getCOROUTINE_SUSPENDED();
|
|
if (startUndispatchedOrReturn == coroutine_suspended) {
|
|
DebugProbesKt.probeCoroutineSuspended(continuation);
|
|
}
|
|
return startUndispatchedOrReturn;
|
|
}
|
|
|
|
public static final CoroutineScope CoroutineScope(CoroutineContext coroutineContext) {
|
|
CompletableJob Job$default;
|
|
if (coroutineContext.get(Job.Key) == null) {
|
|
Job$default = JobKt__JobKt.Job$default(null, 1, null);
|
|
coroutineContext = coroutineContext.plus(Job$default);
|
|
}
|
|
return new ContextScope(coroutineContext);
|
|
}
|
|
|
|
public static /* synthetic */ void cancel$default(CoroutineScope coroutineScope, CancellationException cancellationException, int i, Object obj) {
|
|
if ((i & 1) != 0) {
|
|
cancellationException = null;
|
|
}
|
|
cancel(coroutineScope, cancellationException);
|
|
}
|
|
|
|
public static final void cancel(CoroutineScope coroutineScope, CancellationException cancellationException) {
|
|
Job job = (Job) coroutineScope.getCoroutineContext().get(Job.Key);
|
|
if (job == null) {
|
|
throw new IllegalStateException(("Scope cannot be cancelled because it does not have a job: " + coroutineScope).toString());
|
|
}
|
|
job.cancel(cancellationException);
|
|
}
|
|
|
|
public static final void ensureActive(CoroutineScope coroutineScope) {
|
|
JobKt.ensureActive(coroutineScope.getCoroutineContext());
|
|
}
|
|
}
|