2021-12-17 21:59:34 +00:00
|
|
|
package b.a.d;
|
2021-07-24 02:37:17 +00:00
|
|
|
|
2021-08-13 06:23:11 +00:00
|
|
|
import com.discord.utilities.rx.ObservableExtensionsKt;
|
2021-11-02 06:38:17 +00:00
|
|
|
import d0.z.d.m;
|
2021-08-13 06:23:11 +00:00
|
|
|
import rx.Observable;
|
|
|
|
/* compiled from: AppTransformers.kt */
|
2022-03-07 09:34:54 +00:00
|
|
|
/* loaded from: classes.dex */
|
2021-08-13 06:23:11 +00:00
|
|
|
public final class n<T, R> implements Observable.c<T, T> {
|
2021-12-02 18:53:44 +00:00
|
|
|
public static final n j = new n();
|
2021-07-24 02:37:17 +00:00
|
|
|
|
2021-11-02 06:38:17 +00:00
|
|
|
@Override // j0.k.b
|
2021-08-13 06:23:11 +00:00
|
|
|
public Object call(Object obj) {
|
|
|
|
Observable observable = (Observable) obj;
|
|
|
|
m.checkNotNullExpressionValue(observable, "observable");
|
2022-03-21 18:52:30 +00:00
|
|
|
return ObservableExtensionsKt.computationBuffered(observable).r();
|
2021-07-24 02:37:17 +00:00
|
|
|
}
|
|
|
|
}
|