Google Signin Streams.md

fun googleSignInOptionsObservable() : Observable<GoogleSignInOptions> =
  Observable.just(
  GoogleSignInOptions.Builder(GoogleSignInOptions.DEFAULT_SIGN_IN)
   .requestIdToken(activity.getString(R.string.default_web_client_id))
   .requestEmail()
   .build())

fun googleApiClientObservable(gso : GoogleSignInOptions) : Observable<GoogleApiClient> =
  observable<GoogleApiClient> { subscriber ->
     var googleClient : GoogleApiClient? = null

     googleClient =
      GoogleApiClient.Builder(activity)
       .addConnectionCallbacks(object : GoogleApiClient.ConnectionCallbacks {
           override fun onConnected(var1 : Bundle?) {
               subscriber.onNext(googleClient)
               subscriber.onCompleted()
           }

           override fun onConnectionSuspended(var1 : Int) {
               subscriber.onError(Exception("onConnectionSuspended"))
               subscriber.onCompleted()
           }
       })
       .enableAutoManage(activity, { subscriber.onError(Exception(it.errorMessage)) })
       .addApi(GmsAuth.GOOGLE_SIGN_IN_API, gso)
       .build()
 }

fun continueWithGoogleRegister() = google.setOnClickListener {
    subscription!! +=
     googleSignInOptionsObservable()
      .flatMap { googleApiClientObservable(it) }
      .subscribeOn(Schedulers.newThread())
      .observeOn(AndroidSchedulers.mainThread())
      .map { GmsAuth.GoogleSignInApi.getSignInIntent(it) }
      .subscribe (
       { startActivityForResult(it, ReqCodeGoogleSignIn) },
       { context.toastLong(R.string.common_google_play_services_api_unavailable_text) })
}