24 lines
1.2 KiB
Java
24 lines
1.2 KiB
Java
package com.discord.widgets.chat.input;
|
|
|
|
import com.discord.api.channel.Channel;
|
|
import com.discord.utilities.rx.ObservableExtensionsKt;
|
|
import com.discord.utilities.rx.ObservableExtensionsKt$filterNull$1;
|
|
import com.discord.utilities.rx.ObservableExtensionsKt$filterNull$2;
|
|
import d0.z.d.m;
|
|
import j0.k.b;
|
|
import rx.Observable;
|
|
/* compiled from: ChatInputViewModel.kt */
|
|
public final class ChatInputViewModel$createAndGotoThread$1<T, R> implements b<Channel, Observable<? extends Channel>> {
|
|
public final /* synthetic */ ChatInputViewModel this$0;
|
|
|
|
public ChatInputViewModel$createAndGotoThread$1(ChatInputViewModel chatInputViewModel) {
|
|
this.this$0 = chatInputViewModel;
|
|
}
|
|
|
|
public final Observable<? extends Channel> call(Channel channel) {
|
|
Observable<R> F = ChatInputViewModel.access$getStoreChannels$p(this.this$0).observeChannel(channel.h()).x(ObservableExtensionsKt$filterNull$1.INSTANCE).F(ObservableExtensionsKt$filterNull$2.INSTANCE);
|
|
m.checkNotNullExpressionValue(F, "filter { it != null }.map { it!! }");
|
|
return ObservableExtensionsKt.computationLatest(ObservableExtensionsKt.takeSingleUntilTimeout$default(F, 0, false, 3, null));
|
|
}
|
|
}
|