与RxJava2同步上传文件

Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        // 读取文件内容
        File file = new File("path/to/file");
        byte[] data = readFile(file);

        // 上传文件
        String result = uploadFile(data);

        // 发射上传结果
        emitter.onNext(result);
        emitter.onComplete();
    }
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(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() {
        // 上传完成后的操作
    }
});