Я пытаюсь использовать combLatest с несколькими RxTextViews, и я подумал, что правильно утилизировал свои Disposables, но похоже, что я все еще получаю утечку памяти.
val one = RxTextView.afterTextChangeEvents(one)
val two = RxTextView.afterTextChangeEvents(two)
val three = RxTextView.afterTextChangeEvents(three)
val four = RxTextView.afterTextChangeEvents(four)
val five = RxTextView.afterTextChangeEvents(five)
val disposable = Observables.combineLatest(one, two, three, four, five) { oneEvent, twoEvent, threeEvent, fourEvent, fiveEvent ->
//combining happening with these strings: oneEvent.view().text.toString }
.skip(1)
.debounce(1000, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe {
//network call
}
compositeDisposable.add(disposable)
}
А потом в моем onStop
Я распоряжаюсь им.
override fun onStop() {
super.onStop()
if (!compositeDisposable.isDisposed) {
compositeDisposable.dispose()
}
}
Я читал, что если на некоторые представления ссылаются в методе onNext (), то существует потенциальное исключение NullPointerException, которое, как я полагаю, происходит.Вот мой NPE, который я получаю:
fatal Exception: java.lang.NullPointerException: view == null
at com.jakewharton.rxbinding2.internal.Preconditions.checkNotNull(Preconditions.java:27)
at com.jakewharton.rxbinding2.widget.RxTextView.afterTextChangeEvents(RxTextView.java:159)
at MyFragment$setUpTextListeners$1.execute(MyFragment.kt:170)
Вот фрагмент, который я использую:
private lateinit var viewModel: MyViewModel
private lateinit var binding: FragmentMyThingsBinding
private val compositeDisposable = CompositeDisposable()
override fun onCreateView(inflater: LayoutInflater, container: ViewGroup?, savedInstanceState: Bundle?): View? {
binding = FragmentMyThingsBinding.inflate(inflater, container, false)
viewModel = ViewModelProviders.of(this).get(MyViewModel::class.java)
binding.viewModel = viewModel
//calls to kick off business logic
return binding.root
}
override fun onStart() {
super.onStart()
setUpTextListeners()
}
override fun onStop() {
super.onStop()
if (!compositeDisposable.isDisposed) {
compositeDisposable.dispose()
}
}
private fun setUpTextListeners() {
val one = RxTextView.afterTextChangeEvents(one)
val two = RxTextView.afterTextChangeEvents(two)
val three = RxTextView.afterTextChangeEvents(three)
val four = RxTextView.afterTextChangeEvents(four)
val five = RxTextView.afterTextChangeEvents(five)
compositeDisposable.add(Observables.combineLatest(one, two, three, four, five) { oneEvent, twoEvent, threeEvent, fourEvent, fiveEvent ->
//combine here using oneEvent.view().text.toString }
.skip(1)
.debounce(1000, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe {
//network call
})
}
}