Why does this test fail?

val progress = Channel<Long>(Channel.CONFLATED)
			val progressList = GlobalScope.async { progress.toList() }

			runBlocking {
				val progressResult = (0L..20L step 2).onEach { progress.offer(it) }
				progress.close()

				assertThat(progressResult.toList()).toBe(progressList.await())
			}

progressList

is []...

not enough time to dispatch those updates. You use offer which doesn’t suspend

send also doesn't work 🤕

because also not dispatched probably

?

Because this is how conflaited channel works

Thanks, that's much clearer! So in a real download, it would work since there is some time while reporting download progress, or will

toList()

return immediately while progress is still being sent..? I don't necessarily suspend while receiving bytes...

But why you need this for progress?

It's not that fast, I'm just unit testing, so I have a mock server... I just wanted to make sure that I'm getting some progress, I just didn't get any...

You run it in runBlocking and do not give dispatcher chance to dispatch any other coroutine between offer calls

yield still doesn't work... only delay(1) or Thread.sleep(20), Thread.sleep(10) sometimes works, sometimes doesn't 🙃 I need at least the last part to be able to sum up the total bytes downloaded... but you're saying that in that case I'll be getting it since it's not going to go so fast...

If you want overall amount of bytes, just return it as result of suspend function