LiveStreamViewModel.kt

    private fun requestChannel() {
        val channelData = mapOf("name" to "Live stream chat")
        val request = QueryChannelRequest()
            .withData(channelData)
            .withMessages(20)
            .withWatch()

        channelController.query(request).enqueue {
            if (it.isSuccess) {
                _viewState.postValue(State.Messages(it.data().messages))
            } else {
                _viewState.postValue(State.Error("QueryChannelRequest error"))
                Timber.e(it.error())
            }
        }
    }

    private fun subscribeToNewMessageEvent() {
        chatClient.events().subscribe {
            if (it is NewMessageEvent) {
                _viewState.postValue(State.NewMessage(it.message))
            }
        }
    }