Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
class ChatViewModel(
private val chatLogic: ChatLogic
) : RxViewModel() {
fun observeChatMessages() {
disposables += chatLogic.chatMessages
// 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