How replace callback by Kotlin's coroutines

Question

I need to do the next:

Check is exist profile
If exist then start async http request (getAdvertising()) by Retrofit lib
if not exist then first loading profile from remote (by Retrofit) AND if success get result then start async http request (getAdvertising())

I do this by callback like this:

    fun getAdvertising(callback: Callback<List<Advertising>>) {
        val call = myRestClient.advertising
        executeAsync(call, callback)
    }

  private fun <T> executeAsync(call: Call<T>, callback: Callback<T>) {
        val currentApplicationProfileResponse = foService.applicationProfileResponse
        if (currentApplicationProfileResponse == null) {
            getApplicationProfile(object : DefaultRestClientCallback<ApplicationProfileResponse>() {

                override fun onTransportResponse(transportResponse: TransportResponse) {
                    super.onTransportResponse(transportResponse)
                    if (transportResponse.isSuccessful) {
                        //asynchronously
                        call.enqueue(callback)
                    } else { // not success
                        if (callback is DefaultRestClientCallback<*>) {
                            callback.onTransportResponse(transportResponse)
                        } else {
                            callback.onResponse(call, transportResponse.originalResponse as Response<T>?)
                        }
                    }
                }
            })
        } else { // appProfile is not null
            //asynchronously
            call.enqueue(callback)
        }
    }

Nice it's work fine.

But is to much code. Is it possible to repalace Callback by Kotlin's coroutines?

Retrofit has support now for coroutines: proandroiddev.com/… — Alex Hart
– Alex Hart, Commented Jul 29, 2019 at 12:47
You should use Retrofit 2.6.0 it now supports coroutines or you can do this stackoverflow.com/questions/48552925/… — m3g4tr0n
– m3g4tr0n, Commented Jul 29, 2019 at 13:17

Ahmed mohamed hussien · Accepted Answer · 2019-07-29 14:01:58Z

private fun getADvertise(onResult: (ArrayList<String>) -> Unit = {}) {
    CoroutineScope(Dispatchers.IO).launch {
        //Do Request To get Data using retrofit
        val result = ArrayList<String>()//result from retrofit
        withContext(Dispatchers.Main)
        {
            onResult(result)
        }

    }
}

private fun isProfileExist(): Boolean {
    //true or false
    return true
}

private fun getProfilePicture(id: String, OnResult: (String) -> Unit = {}) {
    CoroutineScope(Dispatchers.IO).launch {
        //Do Request To get Data using retrofit
        val result = "Link"//result from retrofit
        withContext(Dispatchers.Main)
        {
            OnResult(result)
        }

    }
}

//---------your main function------------------>
public fun execute(onResultMain: (ArrayList<String>) -> Unit = {}) {
    val exist = isProfileExist()
    if (exist) {
        getADvertise(onResultMain)
    } else {
        getProfilePicture("id") {

            getADvertise(onResultMain)
        }
    }

}
//onResultMain -> call back used to get result when they are ready ;)

Santanu Sur · Accepted Answer · 2019-07-29 12:58:22Z

2

Use call.execute() ( i.e, synchronous retrofit request ) inside suspend function of coroutine.

 suspend fun <T> executeAsync(call: Call<T>, callback: Callback<T>) {
       try {
           if(foService.applicationProfileResponse != null) {
              if(T is List<Advertising>) {
                 val advertisings = call.execute() // synchronous call 
              } 
           }
       } catch(e : Exception) {
           // handle exception
       } 
 }

Or, add

   .addCallAdapterFactory(CoroutineCallAdapterFactory())

to retrofit builder and use .await() with deferred

    call.await() // call is of type deferred

edited Jul 29, 2019 at 12:58

answered Jul 29, 2019 at 12:51

Santanu Sur

11.5k8 gold badges37 silver badges53 bronze badges

Comments

Liam · Accepted Answer · 2020-07-21 14:25:20Z

1

you can use this way

suspend fun <T> Call<T>.getResult(): T = suspendCoroutine { cont ->
    enqueue(object : Callback<T> {
        override fun onFailure(call: Call<T>, t: Throwable) {
            cont.resumeWithException(t)
        }

        override fun onResponse(call: Call<T>, response: Response<T>) {
            if (response.isSuccessful) {
                cont.resume(response.body()!!)
            } else {
                cont.resumeWithException(ErrorResponse(response.message(), response.code()))
            }
        }

    })
}

class ErrorResponse(message: String, code: Int) : Throwable(message )

edited Jul 21, 2020 at 14:25

Liam

30k28 gold badges143 silver badges206 bronze badges

answered Aug 7, 2019 at 11:39

Khalid Mohammed

896 bronze badges

Collectives™ on Stack Overflow

How replace callback by Kotlin's coroutines

3 Answers 3

Comments

Comments

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related