запрос в другом запросе вызывается несколько раз с помощью rxJava и модификации - PullRequest
Новая
       42

запрос в другом запросе вызывается несколько раз с помощью rxJava и модификации

0 голосов
/ 30 сентября 2019

Я использую MVVM и rxJava и модифицирую для отправки моего запроса. У меня есть нижняя навигационная панель, в которой есть 5 фрагментов, и в одном из них я должен отправить запрос, а после того, как ответ получен, я должен отправить еще один запрос на свой сервер. это мой класс ViewModel: 

class MyViewModel: ViewModel() {

val compositeDisposable = CompositeDisposable()
val myFirstReqLiveData = MutableLiveData<myFirstReqModel>()
val mySecondReqLiveData = MutableLiveData<mySecondReqModel>()

    fun getFirstReq(token:String){

    val firstReqDisposable = RetrofitClientInstance.getRetrofitInterface()
        .getFirstReq(token)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread()).singleElement()
        .subscribe({
                it-> myFirstReqLiveData.value = it
        },{
            errorFirstReqLiveData.value = it
        },{

        })
    compositeDisposable.add(firstReqDisposable)

}

    fun getSecondReq(token:String){

    val secondReqDisposable = RetrofitClientInstance.getRetrofitInterface()
        .getSecondReq(token)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread()).singleElement()
        .subscribe({
                it-> mySecondReqLiveData.value = it
        },{
            errorSecondReqLiveData.value = it
        },{

        })
    compositeDisposable.add(SecondReqDisposable)

}

    override fun onCleared() {
    super.onCleared()
    compositeDisposable.clear()
}

}

, и в моем фрагменте я реализую этот способ: 

class FirstTabFragment : Fragment() {
private lateinit var myViewModel: MyViewModel

override fun onViewCreated(view: View, savedInstanceState: Bundle?) {

myViewModel = ViewModelProviders.of(activity!!).get(MyViewModel::class.java)

        getFirstReq(myViewModel, token!!)
        observeFirstReq(myViewModel)
        observeFirstReqError(myViewModel)

        observeSecondReq(myViewModel)
        observeSecondReqError(myViewModel)
}

    fun getFirstReq(viewModel: MyViewModel, token: String) {
    viewModel.getFirstReq(token)
}

   fun observeFirstReq(viewModel: MyViewModel) {
    viewModel.getFirstReqLiveData().observe(this, Observer { myFirstReqModel ->
   getSecondReq(myViewModel)
    }
   }

   fun getSecondReq(viewModel: MyViewModel, token: String) {
    viewModel.getSecondReq(token)
   }


    fun observeSecondReq(viewModel: MyViewModel) {
    viewModel.getSecondReqLiveData().observe(this, Observer { mySecondReqModel ->
   //do some work with my data
    }
   }

Моя проблема заключается в том, что когда я переключаю свои вкладки, мой второй запрос вызывается несколько раз.

Я думаю, что я назначаю новую подписку каждый раз, когда заново открываю свой фрагмент, поэтому он вызывался несколько раз.

как я могу решить эту проблему?!

Ответы [ 2 ]

2 голосов
/ 30 сентября 2019

Создать ниже класса 

open class Event<out T>(private val content: T) {

    var hasBeenHandled = false
        private set // Allow external read but not write

    /**
     * Returns the content and prevents its use again.
     */
    fun getContentIfNotHandled(): T? {
        return if (hasBeenHandled) {
            null
        } else {
            hasBeenHandled = true
            content
        }
    }

    /**
     * Returns the content, even if it's already been handled.
     */
    fun peekContent(): T = content
}

в Viewmodel изменить следующим образом 

val myFirstReqLiveData = MutableLiveData<Event<myFirstReqModel>>()
val mySecondReqLiveData = MutableLiveData<Event<mySecondReqModel>>()

в классе фрагментов 

fun observeFirstReq(viewModel: MyViewModel) {
    viewModel.getFirstReqLiveData().observe(this, EventObserver { myFirstReqModel ->
   getSecondReq(myViewModel)
    }
   }

изменить 

it-> myFirstReqLiveData.value = it to 
it-> myFirstReqLiveData.value = Event(it)

попробуйте использовать этот способ, если вам это поможет.

1 голос
/ 30 сентября 2019

Вы также можете удалить getSecondReq(myViewModel) из наблюдателя и объединить или объединить ваши запросы.

https://github.com/ReactiveX/RxJava/wiki/Combining-Observables

Примерно так: 

    val disposable = RetrofitClientInstance.getRetrofitInterface()
        .getFirstReq(token)
        .doOnError { errorFirstReqLiveData.value = it }
        .doOnNext { myFirstReqLiveData.value = it }
        .flatMap { t -> getSecondReq(token) }
        .doOnError { errorSecondReqLiveData.value = it }
        .doOnNext { mySecondReqLiveData.value = it }
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread()).singleElement()
        .subscribe()
compositeDisposable.add(disposable)
...