如何用RxJava Single<>包装Firebase OnCompleteListener实现图片上传？

你的代码核心问题是没有把Firebase的异步上传流程和RxJava的Single数据流正确绑定：

• Single.fromCallable是同步执行块，它会在执行完内部代码后立刻返回，不会等待Firebase的异步上传任务完成，导致Single无法发射正确的URL结果。
• 嵌套的addOnCompleteListener回调里的结果完全脱离了Single的数据流，无法传递给订阅的观察者。

修正后的Repository实现 #

我们可以用Single.create()手动控制Single的事件发射，把上传流程的成功结果和错误都正确传递到RxJava的数据流中：

public Single<String> uploadImage(String path) {
    Uri uri = Uri.fromFile(new File(path));
    String fileName = createNewFileName(uri);
    StorageReference ref = firebaseStorage.getReference().child(fileName);

    return Single.create(emitter -> {
        // 启动文件上传任务
        UploadTask uploadTask = ref.putFile(uri);
        
        uploadTask.continueWithTask(task -> {
            if (!task.isSuccessful()) {
                // 上传失败，抛出异常
                throw task.getException();
            }
            // 上传完成，获取下载URL
            return ref.getDownloadUrl();
        }).addOnCompleteListener(task -> {
            if (task.isSuccessful()) {
                Uri downloadUri = task.getResult();
                // 向观察者发射成功结果
                emitter.onSuccess(downloadUri.toString());
            } else {
                // 向观察者发射错误信息
                emitter.onError(task.getException());
            }
        });
    });
}

代码说明 #

1. 用Single.create()创建数据流，通过emitter对象手动控制事件发射：
   • 拿到下载URL时调用emitter.onSuccess()传递结果
   • 任何环节出错时调用emitter.onError()传递异常
2. 保留Firebase的continueWithTask链式逻辑，确保先完成上传再获取URL的流程顺序
3. 所有异常都会被自动传递到ViewModel订阅时的err回调中

ViewModel中的使用（原代码无需修改） #

uploadImage(path)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(url -> {
            // 处理成功获取的图片URL
        }, err -> {
            // 处理上传或URL获取环节的错误
        });

额外优化方案 #

如果你的项目引入了对应RxJava版本的Firebase扩展依赖（比如firebase-firestore-rx-java3），可以用更简洁的方式实现，避免手动创建Single：

public Single<String> uploadImage(String path) {
    Uri uri = Uri.fromFile(new File(path));
    String fileName = createNewFileName(uri);
    StorageReference ref = firebaseStorage.getReference().child(fileName);

    return Single.fromFuture(ref.putFile(uri).continueWithTask(task -> {
        if (!task.isSuccessful()) {
            throw task.getException();
        }
        return ref.getDownloadUrl();
    })).map(Uri::toString);
}

这里利用Single.fromFuture()将Firebase的Task（实现了Future接口）直接转换成Single，再用map()把Uri转为字符串格式。

内容的提问来源于stack exchange，提问作者WHOATEMYNOODLES