package com.seewo.factoryaging.r0;

import j.p0.d.a0;
import j.p0.d.r;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: CameraBurnPresenter.kt */
/* JADX INFO: loaded from: classes.dex */
public final class i extends g {
    private i.a.k.b c;

    /* JADX INFO: Access modifiers changed from: private */
    public static final void q(i iVar, i.a.k.b bVar) {
        r.f(iVar, "this$0");
        h hVarI = iVar.i();
        r.c(hVarI);
        hVarI.p();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final Integer r(a0 a0Var, Long l2) {
        r.f(a0Var, "$direction");
        r.f(l2, "it");
        return Integer.valueOf(a0Var.b == 1 ? 2 : 1);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void s(a0 a0Var, i iVar, Integer num) {
        r.f(a0Var, "$direction");
        r.f(iVar, "this$0");
        r.e(num, "it");
        a0Var.b = num.intValue();
        h hVarI = iVar.i();
        r.c(hVarI);
        hVarI.e(a0Var.b);
        StringBuilder sb = new StringBuilder();
        sb.append("sample_motor run 1 1 ");
        sb.append(num.intValue() == 1 ? "1" : "0");
        sb.append(" 400 3300");
        h.c.d.d.e.b(sb.toString(), false);
    }

    @Override // com.seewo.factoryaging.r0.g
    public void l() {
        final a0 a0Var = new a0();
        a0Var.b = 1;
        this.c = i.a.d.p(0L, 7500L, TimeUnit.MILLISECONDS).c(c()).i(new i.a.m.c() { // from class: com.seewo.factoryaging.r0.a
            @Override // i.a.m.c
            public final void accept(Object obj) {
                i.q(this.a, (i.a.k.b) obj);
            }
        }).C(i.a.q.a.c()).u(i.a.q.a.c()).t(new i.a.m.d() { // from class: com.seewo.factoryaging.r0.c
            @Override // i.a.m.d
            public final Object a(Object obj) {
                return i.r(a0Var, (Long) obj);
            }
        }).h(new i.a.m.c() { // from class: com.seewo.factoryaging.r0.b
            @Override // i.a.m.c
            public final void accept(Object obj) {
                i.s(a0Var, this, (Integer) obj);
            }
        }).w();
    }

    @Override // com.seewo.factoryaging.r0.g
    public void m() {
        i.a.k.b bVar;
        i.a.k.b bVar2 = this.c;
        if (bVar2 != null) {
            Boolean boolValueOf = bVar2 != null ? Boolean.valueOf(bVar2.isDisposed()) : null;
            r.c(boolValueOf);
            if (boolValueOf.booleanValue() || (bVar = this.c) == null) {
                return;
            }
            bVar.dispose();
        }
    }
}