115 lines
4.3 KiB
Java
115 lines
4.3 KiB
Java
|
package o;
|
||
|
|
||
|
import android.content.Context;
|
||
|
import android.os.Bundle;
|
||
|
import android.os.Handler;
|
||
|
import com.google.android.gms.common.ConnectionResult;
|
||
|
import com.google.android.gms.common.api.Api;
|
||
|
import com.google.android.gms.common.api.GoogleApiClient;
|
||
|
import java.util.Arrays;
|
||
|
import java.util.Iterator;
|
||
|
import java.util.List;
|
||
|
import pl.charmas.android.reactivelocation2.observables.GoogleAPIConnectionException;
|
||
|
import pl.charmas.android.reactivelocation2.observables.GoogleAPIConnectionSuspendedException;
|
||
|
|
||
|
/* renamed from: o.guv, reason: case insensitive filesystem */
|
||
|
/* loaded from: classes6.dex */
|
||
|
public abstract class AbstractC15591guv<T> implements InterfaceC13170fSr<T> {
|
||
|
private final Handler b;
|
||
|
private final List<Api<? extends Api.ApiOptions.NotRequiredOptions>> d;
|
||
|
private final Context e;
|
||
|
|
||
|
protected abstract void b(GoogleApiClient googleApiClient, InterfaceC13168fSp<? super T> interfaceC13168fSp);
|
||
|
|
||
|
/* JADX INFO: Access modifiers changed from: protected */
|
||
|
@SafeVarargs
|
||
|
public AbstractC15591guv(guw guwVar, Api<? extends Api.ApiOptions.NotRequiredOptions>... apiArr) {
|
||
|
this.e = guwVar.c;
|
||
|
this.b = guwVar.b;
|
||
|
this.d = Arrays.asList(apiArr);
|
||
|
}
|
||
|
|
||
|
/* renamed from: o.guv$LWm */
|
||
|
/* loaded from: classes6.dex */
|
||
|
class LWm implements GoogleApiClient.ConnectionCallbacks, GoogleApiClient.OnConnectionFailedListener {
|
||
|
private AbstractC15591guv a;
|
||
|
private final InterfaceC13168fSp<? super T> c;
|
||
|
GoogleApiClient d;
|
||
|
|
||
|
private LWm(AbstractC15591guv abstractC15591guv, InterfaceC13168fSp<? super T> interfaceC13168fSp) {
|
||
|
this.a = abstractC15591guv;
|
||
|
this.c = interfaceC13168fSp;
|
||
|
}
|
||
|
|
||
|
@Override // com.google.android.gms.common.api.internal.ConnectionCallbacks
|
||
|
public final void onConnected(Bundle bundle) {
|
||
|
try {
|
||
|
this.a.b(this.d, this.c);
|
||
|
} catch (Throwable th) {
|
||
|
if (this.c.isDisposed()) {
|
||
|
return;
|
||
|
}
|
||
|
this.c.c(th);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
@Override // com.google.android.gms.common.api.internal.ConnectionCallbacks
|
||
|
public final void onConnectionSuspended(int i) {
|
||
|
if (this.c.isDisposed()) {
|
||
|
return;
|
||
|
}
|
||
|
this.c.c(new GoogleAPIConnectionSuspendedException(i));
|
||
|
}
|
||
|
|
||
|
@Override // com.google.android.gms.common.api.internal.OnConnectionFailedListener
|
||
|
public final void onConnectionFailed(ConnectionResult connectionResult) {
|
||
|
if (this.c.isDisposed()) {
|
||
|
return;
|
||
|
}
|
||
|
this.c.c(new GoogleAPIConnectionException("Error connecting to GoogleApiClient.", connectionResult));
|
||
|
}
|
||
|
|
||
|
/* synthetic */ LWm(AbstractC15591guv abstractC15591guv, InterfaceC13168fSp interfaceC13168fSp, byte b) {
|
||
|
this(abstractC15591guv, interfaceC13168fSp);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
@Override // o.InterfaceC13170fSr
|
||
|
public final void b(InterfaceC13168fSp<T> interfaceC13168fSp) throws Exception {
|
||
|
LWm lWm = new LWm(this, interfaceC13168fSp, (byte) 0);
|
||
|
GoogleApiClient.Builder builder = new GoogleApiClient.Builder(this.e);
|
||
|
Iterator<Api<? extends Api.ApiOptions.NotRequiredOptions>> it = this.d.iterator();
|
||
|
while (it.hasNext()) {
|
||
|
builder = builder.addApi(it.next());
|
||
|
}
|
||
|
GoogleApiClient.Builder addOnConnectionFailedListener = builder.addConnectionCallbacks(lWm).addOnConnectionFailedListener(lWm);
|
||
|
Handler handler = this.b;
|
||
|
if (handler != null) {
|
||
|
addOnConnectionFailedListener = addOnConnectionFailedListener.setHandler(handler);
|
||
|
}
|
||
|
final GoogleApiClient build = addOnConnectionFailedListener.build();
|
||
|
lWm.d = build;
|
||
|
try {
|
||
|
build.connect();
|
||
|
} catch (Throwable th) {
|
||
|
if (!interfaceC13168fSp.isDisposed()) {
|
||
|
interfaceC13168fSp.c(th);
|
||
|
}
|
||
|
}
|
||
|
interfaceC13168fSp.d(fSJ.c(new fSP(this, build) { // from class: o.gux
|
||
|
private GoogleApiClient b;
|
||
|
private AbstractC15591guv e;
|
||
|
|
||
|
@Override // o.fSP
|
||
|
public final void c() {
|
||
|
this.b.disconnect();
|
||
|
}
|
||
|
|
||
|
{
|
||
|
this.e = this;
|
||
|
this.b = build;
|
||
|
}
|
||
|
}));
|
||
|
}
|
||
|
}
|