81 lines
2.4 KiB
Java
81 lines
2.4 KiB
Java
package b.a.d;
|
|
|
|
import androidx.annotation.MainThread;
|
|
import androidx.lifecycle.ViewModel;
|
|
import com.discord.app.AppComponent;
|
|
import d0.z.d.m;
|
|
import kotlin.jvm.functions.Function1;
|
|
import kotlin.jvm.internal.DefaultConstructorMarker;
|
|
import rx.Observable;
|
|
import rx.subjects.BehaviorSubject;
|
|
import rx.subjects.PublishSubject;
|
|
import rx.subjects.Subject;
|
|
/* compiled from: AppViewModel.kt */
|
|
/* loaded from: classes.dex */
|
|
public abstract class d0<V> extends ViewModel implements AppComponent {
|
|
private final Subject<Void, Void> unsubscribeSignal;
|
|
private final BehaviorSubject<V> viewStateSubject;
|
|
|
|
public d0() {
|
|
this(null, 1, null);
|
|
}
|
|
|
|
public d0(V v) {
|
|
BehaviorSubject<V> k0 = BehaviorSubject.k0();
|
|
this.viewStateSubject = k0;
|
|
PublishSubject k02 = PublishSubject.k0();
|
|
m.checkNotNullExpressionValue(k02, "PublishSubject.create()");
|
|
this.unsubscribeSignal = k02;
|
|
if (v != null) {
|
|
k0.onNext(v);
|
|
}
|
|
}
|
|
|
|
public /* synthetic */ d0(Object obj, int i, DefaultConstructorMarker defaultConstructorMarker) {
|
|
this((i & 1) != 0 ? null : obj);
|
|
}
|
|
|
|
@Override // com.discord.app.AppComponent
|
|
public Subject<Void, Void> getUnsubscribeSignal() {
|
|
return this.unsubscribeSignal;
|
|
}
|
|
|
|
public final V getViewState() {
|
|
BehaviorSubject<V> behaviorSubject = this.viewStateSubject;
|
|
m.checkNotNullExpressionValue(behaviorSubject, "viewStateSubject");
|
|
return behaviorSubject.n0();
|
|
}
|
|
|
|
public V modifyPendingViewState(V v, V v2) {
|
|
return v2;
|
|
}
|
|
|
|
public final Observable<V> observeViewState() {
|
|
BehaviorSubject<V> behaviorSubject = this.viewStateSubject;
|
|
m.checkNotNullExpressionValue(behaviorSubject, "viewStateSubject");
|
|
return behaviorSubject;
|
|
}
|
|
|
|
@Override // androidx.lifecycle.ViewModel
|
|
public void onCleared() {
|
|
super.onCleared();
|
|
getUnsubscribeSignal().onNext(null);
|
|
}
|
|
|
|
public final V requireViewState() {
|
|
V viewState = getViewState();
|
|
m.checkNotNull(viewState);
|
|
return viewState;
|
|
}
|
|
|
|
@MainThread
|
|
public void updateViewState(V v) {
|
|
this.viewStateSubject.onNext(modifyPendingViewState(getViewState(), v));
|
|
}
|
|
|
|
public final <T> T withViewState(Function1<? super V, ? extends T> function1) {
|
|
m.checkNotNullParameter(function1, "block");
|
|
return (T) function1.invoke(requireViewState());
|
|
}
|
|
}
|