我如何在 android 中通过 RxJava2 实现这一点？

Question

我正在尝试将图像上传到 Firebase 存储，我想通过 RxJava2 实现这一目标。这是我的代码..

public override fun onActivityResult(requestCode: Int, resultCode: Int, data: Intent) {

    if (requestCode == CropImage.CROP_IMAGE_ACTIVITY_REQUEST_CODE) {
        val result = CropImage.getActivityResult(data)
        if (resultCode == Activity.RESULT_OK) {
            val resultUri = result.uri
            var actualImageFile = File(resultUri.path)
            dialogs = SpotsDialog(this, "upload")
            imageCompressor = Compressor(this)
            var image_bitmap = imageCompressor
                    ?.setMaxWidth(200)
                    ?.setMaxHeight(200)
                    ?.setQuality(75)
                    ?.compressToBitmap(actualImageFile)
            profile_image?.setImageBitmap(image_bitmap)
            dialogs?.show()
            try{
            FirebaseStorage.getInstance().reference.child("profile_images").child(FirebaseAuth.getInstance().currentUser?.uid + ".jpg").putFile(resultUri)
                    .addOnCompleteListener { task: Task<UploadTask.TaskSnapshot> ->
                        if (task.isSuccessful) {
                            showMessage("image uploaded")
                            val baos = ByteArrayOutputStream()
                            image_bitmap?.compress(Bitmap.CompressFormat.JPEG, 100, baos)
                            FirebaseStorage.getInstance().reference.child("profile_images").child("thumbs_images").child(FirebaseAuth.getInstance().currentUser?.uid + ".jpg").putBytes(baos.toByteArray())
                                    .addOnCompleteListener { t ->
                                        if (t.isSuccessful) {
                                            dialogs?.dismiss()
                                            showMessage("thumbnail uploaded")
                                        } else {
                                            dialogs?.dismiss()
                                            showMessage("thumbnail error")
                                        }
                                    }
                        } else {
                            showMessage("image error")
                            dialogs?.dismiss()
                        }
                    }
        }catch(es : Exception){
            es.printStackTrace()
        }
        }else if (resultCode == CropImage.CROP_IMAGE_ACTIVITY_RESULT_ERROR_CODE) {
            val error = result.error
        }
    }
}

我想用 RxJava2 做同样的事情，但我不知道该怎么做..请告诉我。提前致谢

Answer 1

您不需要在此过程中使用任何库，如果您只需要将对 Firebase 的调用包装到 RxJava 调用中，我就会这样做：

这是您上传文件的第一个外部调用

fun firebaseFileUploader(uri: Uri) : Single<String> {
return Single.create{ subscriber ->
    FirebaseStorage.getInstance()
            .reference
            .child("profile_images")
            .child("${FirebaseAuth.getInstance().currentUser?.uid}.jpg")
            .putFile(uri)
            .addOnCompleteListener {
                if(it.isSuccessful) {
                    if(!subscriber.isDisposed) {
                        subscriber.onSuccess("Image uploaded")
                    }
                } else {
                    subscriber.onError(Throwable("Error uploading file to firebase, Image Error"))
                }
            }
}

这是您第二次调用上传缩略图

fun firebaseBytesUploader(baos: ByteArrayOutputStream) : Single<String> {
return Single.create { subscriber ->
    FirebaseStorage.getInstance()
            .reference
            .child("profile_images")
            .child("thumbs_images")
            .child("${FirebaseAuth.getInstance().currentUser?.uid}.jpg")
            .putBytes(baos.toByteArray())
            .addOnCompleteListener {
                if(it.isSuccessful) {
                    if(!subscriber.isDisposed) {
                        subscriber.onSuccess("Thumbnail uploaded")
                    }
                } else {
                    subscriber.onError(Throwable("Error uploading thumbnail"))
                }
            }
}

这是启动该过程的方法，它返回给您一个一次性的，以便您可以在您的活动被破坏等情况下处理此流。

fun startuploadRx(uri: Uri, baos: ByteArrayOutputStream) : Disposable {
return firebaseFileUploader(uri)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .flatMap {
            firebaseBytesUploader(baos).subscribeOn(Schedulers.io())
        }
        .doOnSubscribe {
            //show loading dialog
        }
        .doAfterTerminate {
            //dismiss loading dialog
        }
        .subscribe({successMessage ->
            //do something with the success message
        }, {
           //do something with the error message
        })

同样，这只是一个例子，它并不完美，但是是一个很好的起点。希望能帮助到你！