Rxjava search timer

search after delay 400milisec.java

// search text timer
mEdittext = (EditText) findViewById(R.id.editText);
subTextChange = new Subscriber<CharSequence>() {
    @Override
    public void onCompleted() {
        Log.d(TAG, "onCompleted: ");
    }

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

    @Override
    public void onNext(CharSequence charSequence) {
        Log.d(TAG, "search: " + charSequence);
    }
};
Observable.create(new Observable.OnSubscribe<CharSequence>() {
    @Override
    public void call(final Subscriber<? super CharSequence> subscriber) {
        mEdittext.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) {
                subscriber.onNext(s);
            }

            @Override
            public void afterTextChanged(Editable s) {
            }
        });
    }
}).throttleWithTimeout(500, TimeUnit.MILLISECONDS).subscribe(subTextChange);