ChatViewModelFix.kt

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
            })
    }
}