40 lines
1.5 KiB
Java
40 lines
1.5 KiB
Java
package androidx.work;
|
|
|
|
import c.i.b.d.a.a;
|
|
import d0.k;
|
|
import d0.l;
|
|
import java.util.concurrent.CancellationException;
|
|
import kotlinx.coroutines.CancellableContinuation;
|
|
/* compiled from: ListenableFuture.kt */
|
|
public final class ListenableFutureKt$await$$inlined$suspendCancellableCoroutine$lambda$2 implements Runnable {
|
|
public final /* synthetic */ CancellableContinuation $cancellableContinuation;
|
|
public final /* synthetic */ a $this_await$inlined;
|
|
|
|
public ListenableFutureKt$await$$inlined$suspendCancellableCoroutine$lambda$2(CancellableContinuation cancellableContinuation, a aVar) {
|
|
this.$cancellableContinuation = cancellableContinuation;
|
|
this.$this_await$inlined = aVar;
|
|
}
|
|
|
|
@Override // java.lang.Runnable
|
|
public final void run() {
|
|
try {
|
|
CancellableContinuation cancellableContinuation = this.$cancellableContinuation;
|
|
V v = this.$this_await$inlined.get();
|
|
k.a aVar = k.i;
|
|
cancellableContinuation.resumeWith(k.m75constructorimpl(v));
|
|
} catch (Throwable th) {
|
|
Throwable cause = th.getCause();
|
|
if (cause == null) {
|
|
cause = th;
|
|
}
|
|
if (th instanceof CancellationException) {
|
|
this.$cancellableContinuation.j(cause);
|
|
return;
|
|
}
|
|
CancellableContinuation cancellableContinuation2 = this.$cancellableContinuation;
|
|
k.a aVar2 = k.i;
|
|
cancellableContinuation2.resumeWith(k.m75constructorimpl(l.createFailure(cause)));
|
|
}
|
|
}
|
|
}
|