rxjava.kt

class UseCase(private val userDetails:
                                           UserDetails,
                                           val apiService: APIService, val compositeDisposable: CompositeDisposable) {

    val resultsHotObservable:BehaviorSubject<Model> = BehaviorSubject.create()

    fun startRepeadedNetworkRequest(){
        val observable = Observable.defer { startCheckingResults() }
                .repeatWhen { observable -> observable.delay(5, TimeUnit.MILLISECONDS) }
                .takeUntil { it.data = FINISHED) }
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe({ response ->
                    resultsHotObservable.onNext(response)
                }, {
                   
                })
          compositeDisposable.add(observable)
    }

    private fun startCheckingResults():Observable<Model> {
        return apiService.startReceivingData(AuthTokenRequest(
                userDetails.token)
        )
    }
  
    fun onStop(){
      //is triggered from activity to clear current request and prevent network request from being executed in background
      compositeDisposable.clear()
    }

}