不调用两次：从 ViewModel 调用 Single.just() 到 Activity 的结果答案

【问题标题】：Not call twice: result of call Single.just() from ViewModel to Activity不调用两次：从 ViewModel 调用 Single.just() 到 Activity 的结果
【发布时间】：2020-11-28 20:01:55
【问题描述】：

Android 工作室在 build.gradle 中：

   implementation 'io.reactivex.rxjava2:rxjava:2.2.10'
    implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
    implementation 'com.squareup.retrofit2:adapter-rxjava2:2.4.0'

在我的 ViewModel 中我对此进行了测试：

import android.app.Application
import android.view.View
import androidx.lifecycle.AndroidViewModel
import io.reactivex.Single

    class FilmsRxJavaViewModel(application: Application) : AndroidViewModel(application) {
       
        init {
            Debug.d(TAG, "init:")
            loadData()
        }
    
        fun loadData() {
            Debug.d(TAG, "loadData: first_step")
            var dispose = Single.just(true).subscribe{it -> Debug.d(TAG, "single_result = $it")}
            dispose = Single.just(false).subscribe{it -> Debug.d(TAG, "single_result = $it")}
        }

这里是logcat：

FilmsRxJavaViewModel(12149): init:
FilmsRxJavaViewModel(12149): loadData: first_step
FilmsRxJavaViewModel(12149): single_result = true
FilmsRxJavaViewModel(12149): single_result = false

如您所见，Single.just() single_result 的结果打印了两次。因为我两次调用Single.just()

很好。没错。

现在我想在我的活动中打印Single.just() 的结果：

在我的活动中：

import androidx.lifecycle.ViewModelProviders
class FilmsRxJavaActivity : AppCompatActivity() {

override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        binding = FilmsRxJavaActivityBinding.inflate(layoutInflater)
        val view = binding.root
        setContentView(view)
        init()
    }

    private fun init() {

  val viewModelProvider = ViewModelProviders.of(this)
        filmsRxJavaViewModel = viewModelProvider.get(FilmsRxJavaViewModel::class.java)
        var dispose = filmsRxJavaViewModel.isShowProgressSingle
            ?.subscribe { it ->
                Debug.d(TAG, "initLogic: isShowProgress = $it")
            }
    }

在我的视图模型中

  import android.app.Application
  import android.view.View
  import androidx.lifecycle.AndroidViewModel
  import io.reactivex.Single
    
   class FilmsRxJavaViewModel(application: Application) : AndroidViewModel(application) {

var isShowProgressSingle: Single<Boolean>? = null
    init {
        Debug.d(TAG, "init:")
        loadData()
    }

    fun loadData() {
        Debug.d(TAG, "loadData: first_step")
        isShowProgressSingle = Single.just(true)
        Debug.d(TAG, "loadData: second_step")
        isShowProgressSingle = Single.just(false)
    }

这里是logcat：

FilmsRxJavaViewModel(12311): init:
FilmsRxJavaViewModel(12311): loadData: first_step
FilmsRxJavaViewModel(12311): loadData: second_step

FilmsRxJavaActivity(12311): initLogic: isShowProgress = false

您可以在我的活动中看到isShowProgress = false。

所以它只打印一次。 为什么不打印（两次）：

FilmsRxJavaActivity(12311): initLogic: isShowProgress = true
 FilmsRxJavaActivity(12311): initLogic: isShowProgress = false

【问题讨论】：

标签： android mvvm rx-java2

【解决方案1】：

首先Single.just()操作符是一个静态方法，它创建一个SingleJust<T>类的新对象，你可以订阅它，调用它两次并不意味着它会发出两个项目，它只是创建一个新的对象并将其分配给isShowProgressSingle。

您要查找的是 Observable 或 Flowable 可以发射多个项目的项目，例如：

 isShowProgressObservable = Observable.fromArray(true,false)

如果你想创建一个流来显示你的进度，一个简单的解决方案是ReplaySubject，它是Observable 的子类，你可以像这样创建和使用它：

 val progress = ReplaySubject.create<Boolean>()
 progress.onNext(true)
 progress.onNext(false)
 progress.subscribe{
      //do your thing
 }

【讨论】：