Rxjava for handle event

rx click event.java

// sample 3 UI event
mButton = (Button) findViewById(R.id.button);
Observable<View> clickEventObservable = Observable.create(new Observable.OnSubscribe<View>() {
    @Override
    public void call(final Subscriber<? super View> subscriber) {
        mButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                subscriber.onNext(v);
            }
        });
    }
});

clickEventObservable.subscribe(new Subscriber<View>() {
    @Override
    public void onCompleted() {
        Log.d(TAG, "onCompleted: ");
    }

    @Override
    public void onError(Throwable e) {
        Log.d(TAG, "onError: "+e.getMessage());
    }

    @Override
    public void onNext(View view) {
        Log.d(TAG, "onNext: clicked");
    }
});