Status emission problem

[SumitProgrammer5955]

When I start download something and then i cancel after 2 to 3 second after repeating this 2 to 3 time in the 4th time when I finally downloaded that file all the previous emission of those file also emitted like PROGRESS 4 times, SUCCESS 4 times below

Logs :
collectLatest ketch QUEUED
collectLatest ketch QUEUED
collectLatest ketch QUEUED
collectLatest ketch QUEUED
collectLatest ketch STARTED
collectLatest ketch STARTED
collectLatest ketch STARTED
collectLatest ketch STARTED
collectLatest ketch PROGRESS
collectLatest ketch PROGRESS
collectLatest ketch PROGRESS
collectLatest ketch PROGRESS
collectLatest ketch SUCCESS
collectLatest ketch SUCCESS
collectLatest ketch SUCCESS
collectLatest ketch SUCCESS

What I expect is after QUEUED status all the STARTED, PROGRESS and SUCCESS should be called only once.

[khushpanchal]

which version you are using, in version 2.0.1, you can use observeDownloadById

You can see the function in DownloadManager, added distinctUntilChanged so it is only observed again when something changes in DownloadModel
fun observeDownloadById(id: Int): Flow<DownloadModel> { return downloadDao.getEntityByIdFlow(id).filterNotNull().distinctUntilChanged().map { entity -> entity.toDownloadModel() } }

[SumitProgrammer5955]

Thanks for your time.

I alredy did this but it wont work here is the code.

suspend fun Context.myKetchObserver(id : Int, callback:(DownloadModel) -> Unit) {
ketchDownloadHelper().observeDownloadById(id)
.distinctUntilChangedBy{ it.status }
.collectLatest {
Log.d("sumit download", "collectLatest ketch ${it.status.name}")
callback(it)
}
}

[khushpanchal]

Are you cancelling the scope from which you are calling it, before downloading it again?

Since observeDownloadById is returning the flow every time you call it, it will start observing, so if your scope is not cancelled, it will call multiple times.

For e.g: something like this,

 job?.cancel()
            job = viewLifecycleOwner.lifecycleScope.launch {
                repeatOnLifecycle(Lifecycle.State.STARTED) {
                    ketch.observeDownloadById(id)
                        .flowOn(Dispatchers.IO)
                        .collect {
                            adapter.submitList(listOf(it))
                            Log.i("Testing", "${it.status}")
                        }
                }
            }