package c.a.p;

import c.a.p.k;
import com.discord.player.AppMediaPlayer;
import i0.j.b.a;
import java.util.concurrent.TimeUnit;
import rx.Observable;
import rx.Subscription;
import rx.functions.Action1;
import rx.subjects.PublishSubject;
/* compiled from: AppMediaPlayer.kt */
public final class e<T> implements Action1<k.c> {
    public final /* synthetic */ AppMediaPlayer i;

    public e(AppMediaPlayer appMediaPlayer) {
        this.i = appMediaPlayer;
    }

    /* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
    @Override // rx.functions.Action1
    public void call(k.c cVar) {
        int i = cVar.b;
        if (i == 2) {
            PublishSubject<AppMediaPlayer.Event> publishSubject = this.i.a;
            publishSubject.j.onNext(AppMediaPlayer.Event.b.a);
        } else if (i == 3) {
            PublishSubject<AppMediaPlayer.Event> publishSubject2 = this.i.a;
            publishSubject2.j.onNext(AppMediaPlayer.Event.a.a);
            AppMediaPlayer appMediaPlayer = this.i;
            Subscription subscription = appMediaPlayer.b;
            if (subscription != null) {
                subscription.unsubscribe();
            }
            appMediaPlayer.b = Observable.D(500, 500, TimeUnit.MILLISECONDS, appMediaPlayer.i).J().H(a.a()).V(new g(appMediaPlayer), new h(appMediaPlayer));
        } else if (i == 4) {
            PublishSubject<AppMediaPlayer.Event> publishSubject3 = this.i.a;
            publishSubject3.j.onNext(AppMediaPlayer.Event.e.a);
            Subscription subscription2 = this.i.b;
            if (subscription2 != null) {
                subscription2.unsubscribe();
            }
            AppMediaPlayer appMediaPlayer2 = this.i;
            PublishSubject<AppMediaPlayer.Event> publishSubject4 = appMediaPlayer2.a;
            publishSubject4.j.onNext(new AppMediaPlayer.Event.c(appMediaPlayer2.f.J()));
        }
    }
}