Use withLatestFrom to get message text for sending, instead of relying on state

import io.reactivex.Observable

import io.reactivex.android.schedulers.AndroidSchedulers

import io.reactivex.rxkotlin.plusAssign

import io.reactivex.rxkotlin.withLatestFrom

import io.reactivex.schedulers.Schedulers

import javax.inject.Inject

class ComposeViewModel(val threadId: Long) : QkViewModel<ComposeView, ComposeState>(ComposeState(editingMode = threadId == 0L)) {

class ComposeViewModel(threadId: Long) : QkViewModel<ComposeView, ComposeState>(ComposeState(editingMode = threadId == 0L)) {

    @Inject lateinit var context: Context

    @Inject lateinit var contactsRepo: ContactRepository

                view.chipSelectedIntent.map { contact ->

                    { contacts: List<Contact> -> contacts.toMutableList().apply { add(contact) } }

                })

                .scan(listOf<Contact>(), { previousState, reducer -> reducer(previousState) })

                .subscribe { contacts -> newState { it.copy(selectedContacts = contacts) } }

                .scan(state.value!!.contacts, { previousState, reducer -> reducer(previousState) })

                .doOnNext { contacts -> newState { it.copy(selectedContacts = contacts) } }

                .subscribe()

        intents += view.textChangedIntent.subscribe { text ->

            newState { it.copy(draft = text.toString(), canSend = text.isNotEmpty()) }

        }

        intents += view.sendIntent.subscribe {

            val previousState = state.value!!

        intents += view.sendIntent

                .withLatestFrom(view.textChangedIntent, { _, body -> body })

                .map { body -> body.toString() }

                .subscribe { body ->

                    val threadId = conversation?.id ?: 0

                    val address = conversation?.contacts?.first()?.address.orEmpty()

            sendMessage.execute(SendMessage.Params(threadId, address, previousState.draft))

                    sendMessage.execute(SendMessage.Params(threadId, address, body))

                    newState { it.copy(draft = "", canSend = false) }

                }

    }

    fun dataChanged() {

        conversation?.id?.let { threadId ->

            markRead.execute(threadId)

        }

    }

}

 No newline at end of file