0
点赞
收藏
分享

微信扫一扫

Unable to create call adapter for kotlinx.coroutines.Deferred

非衣所思 2022-02-27 阅读 156


​​​

背景

在使用Kotlin coroutines结合Retrofit获取网络数据时,出现如下报错:

2019-04-16 15:24:47.210 20471-20471/com.cxyzy.note E/RepoViewModel$getRepo: java.lang.IllegalArgumentException: Unable to create call adapter for kotlinx.coroutines.Deferred<java.util.List<com.cxyzy.note.network.bean.Repo>>
for method Api.repos
at retrofit2.Utils.methodError(Utils.java:52)
at retrofit2.HttpServiceMethod.createCallAdapter(HttpServiceMethod.java:60)
at retrofit2.HttpServiceMethod.parseAnnotations(HttpServiceMethod.java:34)
at retrofit2.ServiceMethod.parseAnnotations(ServiceMethod.java:36)
at retrofit2.Retrofit.loadServiceMethod(Retrofit.java:168)
at retrofit2.Retrofit$1.invoke(Retrofit.java:147)
at java.lang.reflect.Proxy.invoke(Proxy.java:1006)
at $Proxy1.repos(Unknown Source)

原关键代码:

  1. 构造Retrofit接口代码
Retrofit.Builder()
.baseUrl("https://api.github.com")
.client(provideOkHttpClient(provideLoggingInterceptor()))
.addConverterFactory(GsonConverterFactory.create(GsonBuilder().create()))
.build()
.create(Api::class.java)
  1. Api定义
interface Api {
@GET("/users/{user}/repos")
fun repos(@Path("user") user: String, @Query("page") page: Int, @Query("per_page") perPage: Int): Deferred<List<Repo>>
}

简介方案

  1. 增加CoroutineCallAdapterFactory
import kotlinx.coroutines.CompletableDeferred
import kotlinx.coroutines.Deferred
import retrofit2.*
import java.lang.reflect.ParameterizedType
import java.lang.reflect.Type

class CoroutineCallAdapterFactory private constructor() : CallAdapter.Factory() {
companion object {
@JvmStatic
@JvmName("create")
operator fun invoke() = CoroutineCallAdapterFactory()
}

override fun get(
returnType: Type,
annotations: Array<out Annotation>,
retrofit: Retrofit
): CallAdapter<*, *>? {
if (Deferred::class.java != getRawType(returnType)) {
return null
}
if (returnType !is ParameterizedType) {
throw IllegalStateException(
"Deferred return type must be parameterized as Deferred<Foo> or Deferred<out Foo>")
}
val responseType = getParameterUpperBound(0, returnType)

val rawDeferredType = getRawType(responseType)
return if (rawDeferredType == Response::class.java) {
if (responseType !is ParameterizedType) {
throw IllegalStateException(
"Response must be parameterized as Response<Foo> or Response<out Foo>")
}
ResponseCallAdapter<Any>(getParameterUpperBound(0, responseType))
} else {
BodyCallAdapter<Any>(responseType)
}
}

private class BodyCallAdapter<T>(
private val responseType: Type
) : CallAdapter<T, Deferred<T>> {

override fun responseType() = responseType

override fun adapt(call: Call<T>): Deferred<T> {
val deferred = CompletableDeferred<T>()

deferred.invokeOnCompletion {
if (deferred.isCancelled) {
call.cancel()
}
}

call.enqueue(object : Callback<T> {
override fun onFailure(call: Call<T>, t: Throwable) {
deferred.completeExceptionally(t)
}

override fun onResponse(call: Call<T>, response: Response<T>) {
if (response.isSuccessful) {
deferred.complete(response.body()!!)
} else {
deferred.completeExceptionally(HttpException(response))
}
}
})

return deferred
}
}

private class ResponseCallAdapter<T>(
private val responseType: Type
) : CallAdapter<T, Deferred<Response<T>>> {

override fun responseType() = responseType

override fun adapt(call: Call<T>): Deferred<Response<T>> {
val deferred = CompletableDeferred<Response<T>>()

deferred.invokeOnCompletion {
if (deferred.isCancelled) {
call.cancel()
}
}

call.enqueue(object : Callback<T> {
override fun onFailure(call: Call<T>, t: Throwable) {
deferred.completeExceptionally(t)
}

override fun onResponse(call: Call<T>, response: Response<T>) {
deferred.complete(response)
}
})

return deferred
}
}
}
  1. 修改构造Retrofit接口代码,增加callAdapterFactory:​​addCallAdapterFactory(CoroutineCallAdapterFactory())​
Retrofit.Builder()
.baseUrl("https://api.github.com")
.client(provideOkHttpClient(provideLoggingInterceptor()))
.addCallAdapterFactory(CoroutineCallAdapterFactory())
.addConverterFactory(GsonConverterFactory.create(GsonBuilder().create()))
.build()
.create(Api::class.java)

点击关注专栏,查看最新技术分享

更多技术总结好文,请关注:「程序园中猿」

​​​

Unable to create call adapter for kotlinx.coroutines.Deferred_ide​​

Unable to create call adapter for kotlinx.coroutines.Deferred_ide_02​​



举报

相关推荐

0 条评论