如何在MVVM体系结构中使用协程进行改造

Question

我正在MVVM体系结构中具有改造和rxjava的项目中工作，该项目包含一个repository和repositoryImpl包。我想删除rxjava并仅将Kotlin协程用于该项目。但是在搜索并阅读了有关从rxjava迁移到协程的文章后，我没有找到正确和干净的方法。可能请帮助我实现用协程用rxjava实现的本节

MyProjectService.kt：

 @POST("/user/login")
fun login(@Body agentModel: AgentModel): Observable<APIResultModel<AgentModel>>

Repository.kt：

interface Repository {

fun login(
    context: Context,
    userModel: AgentModel,
    callback: (Result<APIResultModel<AgentModel>, RaakebException>) -> Unit

RepositoryImpl.kt：

class RepositoryImpl : Repository {


private val api = RaakebApi.instance

private val prefs by lazy {
    UserPreferences()
}


override fun login(
    context: Context,
    userModel: AgentModel,
    callback: (Result<APIResultModel<AgentModel>, RaakebException>) -> Unit
) {
    val error = showError(callback)

    val result = Consumer<APIResultModel<AgentModel>> { agent ->

        prefs.token = agent.apiObjects.token.toString()
        callback(Result.Success(agent))
    }

    val hashMap = HashMap<String, Any>()
    val deviceModel = DeviceModel()

    deviceModel.uniqueID = DeviceInfoHelper.getDeviceUniqueID(context)
    deviceModel.appVersion = DeviceInfoHelper.getAppVersion()
    deviceModel.platform = "ANDROID"
    deviceModel.sdkVersion = DeviceInfoHelper.getSDKVersion()
    deviceModel.phoneBrand = DeviceInfoHelper.getPhoneBrand()
    deviceModel.phoneModel = DeviceInfoHelper.getPhoneModel()
    //deviceModel.notificationID = Rakeeb.prefs.notification_id

    hashMap["user"] = userModel
    hashMap["device"] = deviceModel

    api.login(userModel)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(result, error)
}

我试图做到，但这是错误的。而且我不知道该如何解决。

MyProjectService.kt：

interface MyProjectService {

@POST("/user/login")
suspend fun login(@Body agentModel: AgentModel): Result<APIResultModel<AgentModel>, RaakebException>

companion object {

    private val prefs by lazy {
        UserPreferences()
    }

    val instance: RaakebApi by lazy {

        val builder = OkHttpClient.Builder()

        builder.addInterceptor {

            val requestBuilder = it.request().newBuilder()

            if (!it.request().url().url().path?.contains("/user/login")!!) {
                requestBuilder.addHeader("auth", prefs.token)
            }

            requestBuilder.addHeader("Content-Type", "application/json")
            it.proceed(requestBuilder.build())
        }

        builder.readTimeout(30, TimeUnit.SECONDS)
        builder.connectTimeout(30, TimeUnit.SECONDS)

        val client = builder.build()

        val retrofitBuilder: Retrofit.Builder = Retrofit.Builder()
            .client(client)
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
            .addCallAdapterFactory(CoroutineCallAdapterFactory())

        return@lazy retrofitBuilder.baseUrl(ConstHelper.SERVER_URL)
            .addConverterFactory(GsonConverterFactory.create()).build()
            .create(RaakebApi::class.java)
    }
}

}

Repository.kt：

interface Repository {

suspend fun login(
    context: Context,
    userModel: AgentModel
) : Result<APIResultModel<AgentModel>, RaakebException>
   companion object {
    val instance: Repository by lazy {
        RepositoryImpl()
    }
}

RepositoryImpl.kt：

class RepositoryImpl : Repository {


private val api = RaakebApi.instance

private val prefs by lazy {
    UserPreferences()
}


override suspend fun login(
    context: Context,
    userModel: AgentModel
): Result<APIResultModel<AgentModel>, RaakebException> = withContext(Dispatchers.IO) {

    when (val response = api.login(userModel)) {
        is Result.Success -> {

           /* val hashMap = HashMap<String, Any>()
            val deviceModel = DeviceModel()

            deviceModel.uniqueID = DeviceInfoHelper.getDeviceUniqueID(context)
            deviceModel.appVersion = DeviceInfoHelper.getAppVersion()
            deviceModel.platform = "ANDROID"
            deviceModel.sdkVersion = DeviceInfoHelper.getSDKVersion()
            deviceModel.phoneBrand = DeviceInfoHelper.getPhoneBrand()
            deviceModel.phoneModel = DeviceInfoHelper.getPhoneModel()
            //deviceModel.notificationID = Rakeeb.prefs.notification_id

            hashMap["user"] = userModel
            hashMap["device"] = deviceModel*/
            return@withContext response.success
        }
        is Result.Error -> {

        }
    }
}

感谢您的帮助。

Answer 1

您可以使用“ suspend”关键字从改型api函数返回您的类型。如果要从存储库中删除rx Observables。但是您需要记住：“协程=单”。您不能像Flowable那样使用它。如果您愿意，我可以为您分享我的项目。我已经将rx更改为协程。