如何将异步任务/ rx java代码转换为rxjava2？

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

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        // 异步任务代码
        // ...
        emitter.onNext(result); // 发送结果
        emitter.onComplete(); // 完成任务
    }
});

Observer<String> observer = new Observer<String>() {
    @Override
    public void onSubscribe(Disposable d) {
        // 订阅时的操作
    }

    @Override
    public void onNext(String result) {
        // 处理接收到的结果
    }

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

    @Override
    public void onComplete() {
        // 处理任务完成的操作
    }
};

observable.subscribe(observer);