I'm experience that the `await()` on my coroutine ...

# coroutines

[johannes.lagos]

I'm experience that the await() on my coroutine doesn't wait to be done before it continue.

[gildor]

Could you please provide an example

[johannes.lagos]

This is my coroutine method:

suspend  fun ServiceHelper.getList(): ListOfWishes {

return suspendCancellableCoroutine { continuation ->

    getAllLists(object : ResponseReceiver<ListOfWishes> {
        override fun onResponse(response: Response<ListOfWishes>?) {
            continuation.resume(response?.data!!)

        }

        override fun onError(response: Response<ErrorList>?) {
            val throwable = Throwable(Util.getFirstErrorSafe(response?.data))
            continuation.resumeWithException(throwable)
        }
    }, RequestUtils.generateUniqueRequestId(), false, null, object : OnRequestListener {
        override fun beforeRequest() {}
        override fun afterRequestBeforeResponse() {}
        override fun afterRequest(isDataSynced: Boolean) {}
    })
}
}

[johannes.lagos]

suspend fun ServiceHelper.wishLists(): Deferred<ListOfWishes> {
return async(CommonPool){
    getWishList()
   }
}

[johannes.lagos]

fun getUpdatedLists(): ListOfWishes?{
    val context = Injector.getContext()
    val serviceHelper = Util.getContentServiceHelper(context) 
    var list = ListOfWishLists()
    launch(Android){
        try {
            list = serviceHelper.wishLists().await()
        }catch (ex: Exception){
            Timber.d("Error: $ex")
        }
    }
    return list

[johannes.lagos]

Important to mention that getUpdatedList is my interop method with old java legacy code

[johannes.lagos]

If I set fun getUpdatedList(): ListOfWishes? = runBlocking{} I experience that it will block the main thread, and the coroutine never reach continuation.resume()

[gildor]

But you cannot use it this way

[gildor]

getUpdatedList is async, you cannot get result without blocking here

[gildor]

also you use launch in wrong way. Launch means start and forget and don’t lock even inside another coroutine, you cannot use it as closure to asign variable (you can but it will not work correctly)

[gildor]

to use this code in java you should return some callback for Java, to allow use non blocking API

[gildor]

for example you can return lambda, as simplest (no error handling) callback

[johannes.lagos]

Thanks for the reply.

[johannes.lagos]

I will refactor the code.

[johannes.lagos]

@gildor how could I lock the coroutine, and wait for the result?

[gildor]

Inside coroutine you can use run{} or async{}.await()

[gildor]

Outside suspended block only runBlocking

[johannes.lagos]

Thx

[gildor]

Any suspend function also suspends (lock free wait) coroutine

[gildor]

Check kotlinx.coroutines docs https://github.com/Kotlin/kotlinx.coroutines/blob/master/kotlinx-coroutines-core/README.md

[gildor]

And coroutine guides, they are really helpful