package vh3; import android.content.Context; import com.linecorp.andromeda.Universe; import em3.q; import kotlin.Deprecated; import kotlin.Pair; import kotlin.jvm.internal.DefaultConstructorMarker; import okhttp3.OkHttpClient; import okhttp3.Response; import tq.h; import uq.w; import us.b; @Deprecated(message = "Use obs module instead. {@link https://wiki.linecorp.com/x/iBWwjw}") public final class o { /* renamed from: c reason: collision with root package name */ public static final b f172275c = new b(null); /* renamed from: a reason: collision with root package name */ public final OkHttpClient f172276a; /* renamed from: b reason: collision with root package name */ public final h f172277b; public static final class a extends sy2.a<us.b<? extends Pair<? extends Response, ? extends String>>> { /* renamed from: c reason: collision with root package name */ public final long f172278c; /* renamed from: d reason: collision with root package name */ public final al0.b f172279d; /* renamed from: e reason: collision with root package name */ public final al0.a f172280e; /* renamed from: f reason: collision with root package name */ public final c f172281f; public a(long j14, al0.b bVar, al0.a aVar, c cVar) { this.f172278c = j14; this.f172279d = bVar; this.f172280e = aVar; this.f172281f = cVar; } @Override // zx2.u public void onComplete() { } @Override // zx2.u public void onError(Throwable th4) { q.f(th4, "e"); uy2.a.b(th4); } @Override // zx2.u public void onNext(Object obj) { us.b bVar = (us.b) obj; q.f(bVar, Universe.EXTRA_STATE); if (bVar instanceof b.d) { al0.a aVar = this.f172280e; if (aVar == null || !aVar.isCanceled()) { al0.b bVar2 = this.f172279d; if (bVar2 != null) { b.d dVar = (b.d) bVar; long j14 = dVar.f167535a; long j15 = this.f172278c; bVar2.b(j14 + j15, dVar.f167536b + j15); return; } return; } dy2.b.a(this.f146730b); } else if (bVar instanceof b.a) { al0.a aVar2 = this.f172280e; if (aVar2 == null || !aVar2.isCanceled()) { al0.b bVar3 = this.f172279d; if (bVar3 != null) { b.a aVar3 = (b.a) bVar; bVar3.b(aVar3.f167530a, aVar3.f167531b); return; } return; } dy2.b.a(this.f146730b); } else if (bVar instanceof b.c) { T t14 = ((b.c) bVar).f167533a; m mVar = (m) this.f172281f; n.w(mVar.f172252c, (Response) t14.component1()); mVar.f172252c.f172265l = (String) t14.component2(); mVar.a(); } else if (bVar instanceof b.C3006b) { b.C3006b bVar4 = (b.C3006b) bVar; m mVar2 = (m) this.f172281f; mVar2.f172252c.f172264k = w.a.UNDEFINED; mVar2.a(); } } } public static final class b extends ss.a<o> { public b(DefaultConstructorMarker defaultConstructorMarker) { } /* Return type fixed from 'java.lang.Object' to match base method */ @Override // ss.a public o a(Context context) { q.f(context, "context"); return new o((OkHttpClient) rb.a.d(context, ir.a.f88731c), (h) rb.a.d(context, h.f151010c), null); } } public interface c { } public o(OkHttpClient okHttpClient, h hVar, DefaultConstructorMarker defaultConstructorMarker) { this.f172276a = okHttpClient; this.f172277b = hVar; } }