2021-06-27 20:44:35 +00:00
|
|
|
package androidx.lifecycle;
|
|
|
|
|
2021-11-08 18:25:28 +00:00
|
|
|
import d0.z.d.m;
|
2021-06-27 20:44:35 +00:00
|
|
|
import kotlin.coroutines.CoroutineContext;
|
2021-07-09 21:07:36 +00:00
|
|
|
import kotlinx.coroutines.CoroutineDispatcher;
|
2021-11-08 18:25:28 +00:00
|
|
|
import s.a.a.n;
|
2021-12-17 22:03:14 +00:00
|
|
|
import s.a.k0;
|
2021-06-27 20:44:35 +00:00
|
|
|
/* compiled from: PausingDispatcher.kt */
|
2021-07-09 21:07:36 +00:00
|
|
|
public final class PausingDispatcher extends CoroutineDispatcher {
|
2021-06-27 20:44:35 +00:00
|
|
|
public final DispatchQueue dispatchQueue = new DispatchQueue();
|
|
|
|
|
2021-07-09 21:07:36 +00:00
|
|
|
@Override // kotlinx.coroutines.CoroutineDispatcher
|
2021-06-27 20:44:35 +00:00
|
|
|
public void dispatch(CoroutineContext coroutineContext, Runnable runnable) {
|
|
|
|
m.checkNotNullParameter(coroutineContext, "context");
|
|
|
|
m.checkNotNullParameter(runnable, "block");
|
|
|
|
this.dispatchQueue.dispatchAndEnqueue(coroutineContext, runnable);
|
|
|
|
}
|
|
|
|
|
2021-07-09 21:07:36 +00:00
|
|
|
@Override // kotlinx.coroutines.CoroutineDispatcher
|
2021-06-27 20:44:35 +00:00
|
|
|
public boolean isDispatchNeeded(CoroutineContext coroutineContext) {
|
|
|
|
m.checkNotNullParameter(coroutineContext, "context");
|
2021-12-17 22:03:14 +00:00
|
|
|
CoroutineDispatcher coroutineDispatcher = k0.a;
|
2022-01-27 00:50:41 +00:00
|
|
|
if (n.f3791b.H().isDispatchNeeded(coroutineContext)) {
|
2021-06-27 20:44:35 +00:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
return !this.dispatchQueue.canRun();
|
|
|
|
}
|
|
|
|
}
|