49 lines
1.9 KiB
Java
49 lines
1.9 KiB
Java
package b.a.p;
|
|
|
|
import b.a.p.k;
|
|
import b.i.a.c.k2;
|
|
import com.discord.player.AppMediaPlayer;
|
|
import j0.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 j;
|
|
|
|
public e(AppMediaPlayer appMediaPlayer) {
|
|
this.j = 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.a;
|
|
if (i == 2) {
|
|
PublishSubject<AppMediaPlayer.Event> publishSubject = this.j.a;
|
|
publishSubject.k.onNext(AppMediaPlayer.Event.b.a);
|
|
} else if (i == 3) {
|
|
PublishSubject<AppMediaPlayer.Event> publishSubject2 = this.j.a;
|
|
publishSubject2.k.onNext(AppMediaPlayer.Event.a.a);
|
|
AppMediaPlayer appMediaPlayer = this.j;
|
|
Subscription subscription = appMediaPlayer.f2730b;
|
|
if (subscription != null) {
|
|
subscription.unsubscribe();
|
|
}
|
|
appMediaPlayer.f2730b = Observable.E(500, 500, TimeUnit.MILLISECONDS, appMediaPlayer.i).K().I(a.a()).W(new g(appMediaPlayer), new h(appMediaPlayer));
|
|
} else if (i == 4) {
|
|
PublishSubject<AppMediaPlayer.Event> publishSubject3 = this.j.a;
|
|
publishSubject3.k.onNext(AppMediaPlayer.Event.e.a);
|
|
Subscription subscription2 = this.j.f2730b;
|
|
if (subscription2 != null) {
|
|
subscription2.unsubscribe();
|
|
}
|
|
AppMediaPlayer appMediaPlayer2 = this.j;
|
|
PublishSubject<AppMediaPlayer.Event> publishSubject4 = appMediaPlayer2.a;
|
|
publishSubject4.k.onNext(new AppMediaPlayer.Event.c(((k2) appMediaPlayer2.f).T()));
|
|
}
|
|
}
|
|
}
|