在哪里订阅findAllAsync().asObserable()而不阻塞UI线程？

public class MainActivity extends AppCompatActivity {
    private Disposable disposable;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // 初始化数据库或数据源
        Realm.init(this);
        RealmConfiguration config = new RealmConfiguration.Builder().build();
        Realm.setDefaultConfiguration(config);

        // 订阅查询操作
        disposable = Realm.getDefaultInstance()
                .where(YourModel.class)
                .findAllAsync()
                .asObservable()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<RealmResults<YourModel>>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        // 订阅开始时的操作
                    }

                    @Override
                    public void onNext(RealmResults<YourModel> results) {
                        // 处理查询结果的操作
                    }

                    @Override
                    public void onError(Throwable e) {
                        // 处理错误的操作
                    }

                    @Override
                    public void onComplete() {
                        // 订阅完成时的操作
                    }
                });
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        // 在Activity销毁时取消订阅
        if (disposable != null && !disposable.isDisposed()) {
            disposable.dispose();
        }
    }
}