Android + RxJava: Listen to view clicks

Android + RxJava: Listen to view clicks

//https://stackoverflow.com/questions/25457737/how-to-create-an-observable-from-onclick-event-android

Observable<View> clickEventObservable = Observable.create(new Observable.OnSubscribe<View>() {
        @Override
        public void call(final Subscriber<? super View> subscriber) {
            viewIWantToMonitorForClickEvents.setOnClickListener(new View.OnClickListener() {
                @Override
                public void onClick(View v) {
                    if (subscriber.isUnsubscribed()) return;
                    subscriber.onNext(v);
                }
            });
        }
    });

    // You can then apply all sorts of operation here
    //you can add throttle to prevent rapid button clicks like so: 
    // clickEventObservable.throttleFirst(600, TimeUnit.MILLISECONDS)
    Subscription subscription = clickEventObservable.flatMap(/*  */);

    // Unsubscribe when you're done with it
    subscription.unsubscribe();