Multiple button clicks using RxAndroid

ButtonObservable.java

public void setClickObservable(final Button button) {
    Subscription subscription = Observable.create(new Observable.OnSubscribe<Integer>() {
        
        @Override
        public void call(final Subscriber<? super Integer> subscriber) {
            
            button.setOnClickListener(new View.OnClickListener() {
                
                @Override
                public void onClick(View v) {
                    subscriber.onNext(1);
                }
                
            });
        }
        
    }).buffer(500, TimeUnit.MILLISECONDS)
      .flatMap(new Func1<List<Integer>, Observable<Boolean>>() {
        
        @Override
        public Observable<Boolean> call(final List<Integer> integers) {
            
            return Observable.create(new Observable.OnSubscribe<Boolean>() {
                
                @Override
                public void call(Subscriber<? super Boolean> subscriber) {
                    if (integers.size() > 1) {
                        subscriber.onNext(true);
                    }
                }
                
            });
            
        }
    })
     .subscribe(new Action1<Object>() {
        
        @Override
        public void call(Object o) {
            if ((Boolean) o) {
                Log.i(TAG, "multiple clicked");
            }
        }
        
    });
}

EditTextObservable.java

public void setTextObservable(final EditText editText) {
    Subscription editTextSubscription = Observable.create(new Observable.OnSubscribe<String>() {
        
        @Override
        public void call(final Subscriber<? super String> subscriber) {

            editText.addTextChangedListener(new TextWatcher() {
                @Override
                public void beforeTextChanged(CharSequence s, int start, int count, int after) {}

                @Override
                public void onTextChanged(CharSequence s, int start, int before, int count) {}

                @Override
                public void afterTextChanged(Editable s) {
                    subscriber.onNext(s.toString());
                }
            });
            
        }
    }).buffer(1200, TimeUnit.MILLISECONDS)
      .flatMap(new Func1<List<String>, Observable<Boolean>>() {
            
            @Override
            public Observable<Boolean> call(final List<String> strings) {
                
                return Observable.create(new Observable.OnSubscribe<Boolean>() {
                    
                    @Override
                    public void call(Subscriber<? super Boolean> subscriber) {
                        if (strings.size() > 1) {
                            Log.i(TAG, "strings size: " + String.valueOf(strings.size()));
                            subscriber.onNext(false);
                        } else {
                            if (editText.getText().length() > 0) {
                                subscriber.onNext(true);
                            }
                            Log.e(TAG, "string size is 0");
                        }
                    }
                    
                });
                
            }
    })
      .subscribe(new Action1<Object>() {
            
            @Override
            public void call(Object o) {
                if ((Boolean) o) {
                    Log.i(TAG, "perform some operation");
                    // Some method call here
                } else {
                    Log.e(TAG, "still editing");
                }
            }
            
    });
}