discord-jadx/app/src/main/java/g0/y.java

83 lines
1.9 KiB
Java
Raw Normal View History

2021-06-27 20:44:35 +00:00
package g0;
import d0.z.d.m;
import java.io.IOException;
import java.io.InterruptedIOException;
import java.util.concurrent.TimeUnit;
/* compiled from: Timeout.kt */
public class y {
public static final y a = new a();
public boolean b;
/* renamed from: c reason: collision with root package name */
2021-09-14 19:31:33 +00:00
public long f2864c;
2021-06-27 20:44:35 +00:00
public long d;
/* compiled from: Timeout.kt */
public static final class a extends y {
@Override // g0.y
public y d(long j) {
return this;
}
@Override // g0.y
public void f() {
}
@Override // g0.y
public y g(long j, TimeUnit timeUnit) {
m.checkParameterIsNotNull(timeUnit, "unit");
return this;
}
}
public y a() {
this.b = false;
return this;
}
public y b() {
this.d = 0;
return this;
}
public long c() {
if (this.b) {
2021-09-14 19:31:33 +00:00
return this.f2864c;
2021-06-27 20:44:35 +00:00
}
throw new IllegalStateException("No deadline".toString());
}
public y d(long j) {
this.b = true;
2021-09-14 19:31:33 +00:00
this.f2864c = j;
2021-06-27 20:44:35 +00:00
return this;
}
public boolean e() {
return this.b;
}
public void f() throws IOException {
if (Thread.interrupted()) {
Thread.currentThread().interrupt();
throw new InterruptedIOException("interrupted");
2021-09-14 19:31:33 +00:00
} else if (this.b && this.f2864c - System.nanoTime() <= 0) {
2021-06-27 20:44:35 +00:00
throw new InterruptedIOException("deadline reached");
}
}
public y g(long j, TimeUnit timeUnit) {
m.checkParameterIsNotNull(timeUnit, "unit");
if (j >= 0) {
this.d = timeUnit.toNanos(j);
return this;
}
2021-09-14 19:31:33 +00:00
throw new IllegalArgumentException(c.d.b.a.a.q("timeout < 0: ", j).toString());
2021-06-27 20:44:35 +00:00
}
public long h() {
return this.d;
}
}