How to perform an async task for every item in a for loop?

Question

I have a list of urls in a mutable list and I want to perform an IO operation, cacheVideo on each of the urls sequentially one after the other

suspend fun cacheVideo(mediaItem: MediaItem) = {
    val videoUrl = mediaItem.mediaUrl
    val uri = Uri.parse(videoUrl)
    val dataSpec = DataSpec(uri)

    val progressListener =
        CacheUtil.ProgressListener { requestLength, bytesCached, newBytesCached ->

            val downloadPercentage: Double = (bytesCached * 100.0
                    / requestLength)
            
            if (downloadPercentage == 100.0) {
                // I WANT TO RETURN HERE
            }
        }

    try {
        CacheUtil.cache(
            dataSpec,
            cache,
            DataSourceFactory?.createDataSource(),
            progressListener,
            null
        );
    } catch (err: Exception) {
        // IF ERROR, THEN RETURN NULL
    }
}

How would I shape the cacheVideo to do that using Coroutines?

uiScope.launch {
 for(item in mediaItems){
  cacheVideo(item) // I WANT TO WAIT HERE BEFORE GOING TO NEXT ITEM
 }
}

You can create an interface callback to get when previous work is done. — Khemraj Sharma
– Khemraj Sharma, Commented Jul 10, 2020 at 9:25

Sergio · Accepted Answer · 2020-07-10 09:44:08Z

You can use suspendCancellableCoroutine to wait for the progress:

suspend fun cacheVideo(mediaItem: MediaItem) = suspendCancellableCoroutine { continuation ->
    val videoUrl = mediaItem.mediaUrl
    val uri = Uri.parse(videoUrl)
    val dataSpec = DataSpec(uri)

    val progressListener =
        CacheUtil.ProgressListener { requestLength, bytesCached, newBytesCached ->

            val downloadPercentage: Double = (bytesCached * 100.0
                    / requestLength)
            
            if (downloadPercentage == 100.0) {
                continuation.resume() // resumes the execution of the corresponding coroutine 
            }
        }

//  continuation.invokeOnCancellation {
//      // clear some resources, cancel tasks, close streams etc if need.
//  }

    try {
        CacheUtil.cache(
            dataSpec,
            cache,
            DataSourceFactory?.createDataSource(),
            progressListener,
            null
        );
    } catch (err: Exception) {
        continuation.resume() // resumes the execution of the corresponding coroutine 
    }
}

Collectives™ on Stack Overflow

How to perform an async task for every item in a for loop?

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related