Using the extension method

PickupFragment.kt

class PickupFragment : Fragment() {

    override fun onStart() {
        super.onStart()
        source().viewStates()
            .debounceIf({ it.isLoading() }, 250, TimeUnit.MILLISECONDS)
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe { data: PickupData ->
                adapter.setData(data)
            }
            .addTo(disposables)
    }
}