Estoy implementando la rutina por primera vez. Estoy siguiendo el patrón MVP para una aplicación de inicio de sesión simple. Aquí está mi flujo de código:
El botón de inicio de sesión en el que se hizo clic seguirá esta dirección:
LoginFragment -> LoginPresenter -> Repositorio -> APIRepository -> RetrofitInterface
La respuesta de inicio de sesión seguirá esta dirección:
RetrofitInterface -> APIRepository -> Repositorio -> LoginPresenter -> LoginFragment
Aquí está el código -
RetrofitInterface.kt
@POST("login") fun loginAPI(@Body loginRequest: LoginRequest): Deferred<LoginResponse>?Aquí está mi Result.kt
sealed class Result<out T : Any> { class Success<out T : Any>(val data: T) : Result<T>() class Error(val exception: Throwable, val message: String = exception.localizedMessage) : Result<Nothing>() }APIRepository.kt
override suspend fun loginAPICall(loginRequest: LoginRequest) : Result<LoginResponse>? { try { val loginResponse = apiInterface?.loginAPI(loginRequest)?.await() return Result.Success<LoginResponse>(loginResponse!!) } catch (e : HttpException) { return Result.Error(e) } catch (e : Throwable) { return Result.Error(e) } }Repositorio.kt
override suspend fun loginUser(loginRequest: LoginRequest): Result<LoginResponse> { if (isInternetPresent(context)) { val result = apiRepositoryInterface?.loginAPICall(loginRequest) if (result is Result.Success<LoginResponse>) { val loginData = result.data cache?.storeData(loginData) } return result!! } else { return Result.Error(Exception()) } }¿Cómo lanzo una rutina ahora en mi presentador? ¿Necesito ejecutar esta llamada a la API en un subproceso en segundo plano y publicar los resultados en el subproceso de la interfaz de usuario?
Debe iniciar una corrutina en un presentador usando el alcance local e inyectar CoroutineContext para poder cambiarlo, por ejemplo, en pruebas unitarias:
class Presenter( private val repo: Repository, private val uiContext: CoroutineContext = Dispatchers.Main ) : CoroutineScope { // creating local scope private var job: Job = Job() // or SupervisorJob() - children of a supervisor job can fail independently of each other // To use Dispatchers.Main (CoroutineDispatcher - runs and schedules coroutines) // in Android add dependency: implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.0.1' override val coroutineContext: CoroutineContext get() = uiContext + job fun detachView() { // cancel the job when view is detached job.cancel() } fun login(request: LoginRequest) = launch { // launching a coroutine val result = repo.loginUser(request) // calling 'loginUser' function will not block the Main Thread, it suspends the coroutine //use result, update UI when (result) { is Success<LoginResponse> -> { /* update UI when login success */ } is Error -> { /* update UI when login error */ } } } }puedes usar coroutine de esta manera
private var parentJob = Job() private val coroutineContext: CoroutineContext get() = parentJob + Dispatchers.Main private val scope = CoroutineScope(coroutineContext) scope.launch(Dispatchers.IO) { // your api call } puede llamar a parentJob.cancel() para cancelar el trabajo o llamarlo onClear of ViewModel