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

GraphQLApi.kt

class GraphQLApi(private val sharedOkHttpClientBuilder: OkHttpClient.Builder) {

    // ...

    fun <D : Operation.Data, V : Operation.Variables> subscribe(subscription: Subscription<D, D, V>): Flowable<Response<D>> {

        // Create our dedicated apollo client
        val apolloClient = ApolloSubscriptionClientFactory(sharedOkHttpClientBuilder)
            .createSubscriptionApolloClient()

        // Perform the actual subscription
        val call = apolloClient.subscribe(subscription)

        // Subscribe using Rx2Apollo
        return Rx2Apollo.from<D>(call)
    }

    // ...
}