Kotlin GoogleApiClient with RxKotlin

Easy handling of GoogleApiClient with RxKotlin

Usage

class TestClass(val context: Context) {

    companion object {
        val TAG = this::class.java.simpleName
    }

    private val googleApiHelperRx: GoogleApiHelperRx = GoogleApiHelperRx()

    fun doSomethingWithGoogleApi() {

        // Define ConnectionCallback which be called after GoogleApiClient connected successfully
        val connCallback = object : GoogleApiHelperRx.GoogleApiClientCallbackRx {
            override fun onConnected(client: GoogleApiClient, emitter: ObservableEmitter<GoogleApiClient>) {
                // Use emitter to control the flow
                Log.w(TAG, "do something cool")
                emitter.onComplete()

                // User client to disconnect from GoogleApiClient
                // client.disconnect()
            }

        }

        googleApiHelperRx.build(context, connCallback)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnComplete {
                    Log.w(TAG, "onComplete")
                }
                .doOnError {
                    Log.w(TAG, "onError" + it.message)
                }
                .subscribe()
    }
}