Gists for https://medium.com/@josiassena/graphql-websocket-subscriptions-on-android-using-apollo-7e7311afdfca

SomePresenterOrViewModelEtc.kt

class SomePresenterOrViewModelEtc(private val api: GraphQLApi) {

    // ...

    fun sunscribeToMessages() {
        val messagesSubscription = OnNewMessagesReceivedSubscription.builder()
            .groupUUID("uuid")
            .build()

        api.subscribe(messagesSubscription)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe({
                // handle results, like adding the result into a list
            }, {
                // handle errors
            }).addTo(compositeDisposable)
    }

    // ...
}