如何在android中将asynctask代码更改为rxandroid代码？

implementation 'io.reactivex.rxjava2:rxjava:2.x.x'
implementation 'io.reactivex.rxjava2:rxandroid:2.x.x'

// 原始的AsyncTask代码
private class MyAsyncTask extends AsyncTask<Void, Void, String> {
    @Override
    protected String doInBackground(Void... voids) {
        // 执行异步任务的逻辑
        return "Task completed";
    }

    @Override
    protected void onPostExecute(String result) {
        // 处理异步任务的结果
        Toast.makeText(MainActivity.this, result, Toast.LENGTH_SHORT).show();
    }
}

// 更改为RxAndroid代码
private void executeTask() {
    Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> emitter) throws Exception {
            // 执行异步任务的逻辑
            emitter.onNext("Task completed");
            emitter.onComplete();
        }
    })
    .subscribeOn(Schedulers.io()) // 指定执行任务的线程
    .observeOn(AndroidSchedulers.mainThread()) // 指定观察者接收结果的线程
    .subscribe(new Observer<String>() {
        @Override
        public void onSubscribe(Disposable d) {
            // 可选的方法，用于取消订阅
        }

        @Override
        public void onNext(String result) {
            // 处理异步任务的结果
            Toast.makeText(MainActivity.this, result, Toast.LENGTH_SHORT).show();
        }

        @Override
        public void onError(Throwable e) {
            // 处理错误情况
        }

        @Override
        public void onComplete() {
            // 完成任务的回调
        }
    });
}