Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
class ChatViewModel(
private val chatLogic: ChatLogic
) : RxViewModel() {
fun observeChatMessages() {
disposables += chatLogic.chatMessages
.observeOn(AndroidSchedulers.mainThread())
.subscribe({
// On next: update the state
}, {
// On error: update the state
})
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment