Disposable subscription = RxTextView.textChangeEvents(etSearch)
                    .debounce(200, TimeUnit.MILLISECONDS)
                    .observeOn(AndroidSchedulers.mainThread())
                    .toFlowable(BackpressureStrategy.BUFFER)
                    .switchMap(new Function<TextViewTextChangeEvent, Publisher<RealmResults<Note>>>() {
                        @Override
                        public Publisher<RealmResults<Note>> apply(TextViewTextChangeEvent event) throws Exception {
                            String etContent = event.getText().toString();
                            if (etContent.length() > 0) {
                                mLv.setVisibility(View.VISIBLE);
                            } else {
                                mLv.setVisibility(View.GONE);
                            }
                            if (etContent.length() > 0) {
                                mLv.setVisibility(View.VISIBLE);
                            } else {
                                mLv.setVisibility(View.GONE);
                            }
                            finalMAdapter.setSearchStr(etContent);
                            if (dirId == MyApplication.DEFAULT_DIR_ID) {
                                return Realm.getDefaultInstance().where(Note.class)
                                    .contains("title", etContent)
                                    .sort("timeMills", Sort.DESCENDING).findAllAsync().asFlowable();
                            } else {
                                return Realm.getDefaultInstance().where(Note.class)
                                    .equalTo("dirId", dirId)
                                    .contains("title", etContent)
                                    .sort("timeMills", Sort.DESCENDING).findAllAsync().asFlowable();
                            }
                        }
                    })
                    .filter(new Predicate<RealmResults<Note>>() {
                        @Override
                        public boolean test(RealmResults<Note> notes) throws Exception {
                            return notes.isLoaded();
                        }
                    })
                    .subscribe(new Consumer<RealmResults<Note>>() {
                        @Override
                        public void accept(RealmResults<Note> notes) throws Exception {
                            mNotes = notes;
                            if (notes != null && notes.size() > 0) {
                                llNoResult.setVisibility(View.GONE);
                            } else {
                                llNoResult.setVisibility(View.VISIBLE);
                            }
                            finalMAdapter.updateAll(mNotes);
                        }
                    }, new Consumer<Throwable>() {
                        @Override
                        public void accept(Throwable throwable) throws Exception {
                            throwable.printStackTrace();
                        }
                    });

//8.0
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
    NotificationManager mNotificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
    // 通知渠道的id
    String id = "你的渠道id";
    // 用户可以看到的通知渠道的名字.
    CharSequence name = getString(R.string.app_name);
    // 用户可以看到的通知渠道的描述
    String description = getString(R.string.app_push_message_hint);
    int importance = NotificationManager.IMPORTANCE_HIGH;
    NotificationChannel mChannel = new NotificationChannel(id, name, importance);
    mChannel.setLockscreenVisibility(Notification.VISIBILITY_PUBLIC);
    // 配置通知渠道的属性
    mChannel.setDescription(description);
    // 设置通知出现时的闪灯（如果 android 设备支持的话）
    mChannel.enableLights(true);
    mChannel.setLightColor(Color.RED);
    mChannel.setSound(Uri.parse("android.resource://" + BaseUtil.getPackageInfo(BaseUtil.getApp()).packageName + "/" + R.raw.hint_zz_four), null);
    // 设置通知出现时的震动（如果 android 设备支持的话）
    mChannel.enableVibration(true);
    mChannel.setVibrationPattern(new long[]{100, 200, 300, 400, 500, 400, 300, 200, 400});
    //最后在notificationmanager中创建该通知渠道
    if (mNotificationManager != null) {
        mNotificationManager.createNotificationChannel(mChannel);
    }
}