package com.seewo.ota.s;

import e.a.h;
import e.a.k;
import e.a.l;

/* JADX INFO: compiled from: RxLifecycle.java */
/* JADX INFO: loaded from: classes.dex */
public class c {
    private e.a.r.a a;

    /* JADX INFO: Access modifiers changed from: private */
    public void c(e.a.r.b bVar) {
        this.a.c(bVar);
    }

    public <T> l<T, T> a() {
        return new l() { // from class: com.seewo.ota.s.b
            @Override // e.a.l
            public final k a(h hVar) {
                return this.a.e(hVar);
            }
        };
    }

    public void b() {
        if (this.a == null) {
            this.a = new e.a.r.a();
        }
    }

    public /* synthetic */ k e(h hVar) {
        return hVar.p(new e.a.t.c() { // from class: com.seewo.ota.s.a
            @Override // e.a.t.c
            public final void accept(Object obj) {
                this.a.c((e.a.r.b) obj);
            }
        }).T(e.a.x.a.b()).G(e.a.q.b.a.a());
    }

    public void f() {
        e.a.r.a aVar = this.a;
        if (aVar != null) {
            aVar.d();
        }
    }
}