如何在后台线程中使用RX从android的资源文件夹中读取文件

dependencies {
    implementation 'io.reactivex.rxjava3:rxjava:3.x.x'
    implementation 'io.reactivex.rxjava3:rxandroid:3.x.x'
}

Observable.create(new ObservableOnSubscribe<File>() {
    @Override
    public void subscribe(ObservableEmitter<File> emitter) throws Exception {
        // 执行文件读取操作
        File file = getFileFromResource(context, resourceId);
        
        // 发送文件对象给观察者
        emitter.onNext(file);
        emitter.onComplete();
    }
}).subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .subscribe(new Observer<File>() {
      @Override
      public void onSubscribe(Disposable d) {
          // 可选的方法，用于在订阅时进行一些初始化操作
      }

      @Override
      public void onNext(File file) {
          // 文件读取成功，在这里处理读取到的文件
      }

      @Override
      public void onError(Throwable e) {
          // 文件读取失败，处理异常
      }

      @Override
      public void onComplete() {
          // 文件读取完成，可选的方法，用于在完成时进行一些操作
      }
  });

private File getFileFromResource(Context context, int resourceId) {
    InputStream inputStream = null;
    FileOutputStream outputStream = null;
    try {
        // 获取资源文件的输入流
        inputStream = context.getResources().openRawResource(resourceId);
        
        // 创建一个临时文件，用于保存资源文件
        File tempFile = File.createTempFile("temp", null, context.getCacheDir());
        
        // 将输入流写入临时文件
        outputStream = new FileOutputStream(tempFile);
        byte[] buffer = new byte[4096];
        int bytesRead;
        while ((bytesRead = inputStream.read(buffer)) != -1) {
            outputStream.write(buffer, 0, bytesRead);
        }
        
        // 返回临时文件对象
        return tempFile;
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 关闭输入流和输出流
        try {
            if (inputStream != null) {
                inputStream.close();
            }
            if (outputStream != null) {
                outputStream.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    return null;
}