Модификация LiveDataCallAdapter не вызывает функцию адаптации (вызов) - PullRequest
Новая
       38

Модификация LiveDataCallAdapter не вызывает функцию адаптации (вызов)

1 голос
/ 19 апреля 2019

Пытаясь решить эту проблему около 4 дней, помогите, пожалуйста.Я создаю приложение с API отдыха (модернизация), попробуйте реализовать LiveDataCallAdapter из примеров Google https://github.com/googlesamples/android-architecture-components/tree/master/GithubBrowserSample,, но модернизация не вызывает метод адаптера, адаптируемый для получения ответа от сервера.Я редактирую только NetworkBoundResourse (для работы без БД). Попытка поставить точки останова, после того, как я запускаю репо (вход в систему), LiveDataCallAdapter весело адаптирует (где call.enequeue не хочет запускаться), отладка не вызывает

Вот мой кусок кода, thx

Предоставление моего экземпляра службы 

@Singleton
   @Provides
   fun provideRetrofit(): BrizSmartTVService {
       return Retrofit.Builder()
           .baseUrl(baseUrl)
           .addConverterFactory(GsonConverterFactory.create())
           .addCallAdapterFactory(LiveDataCallAdapterFactory())
           .build()
           .create(BrizSmartTVService::class.java)
   }

Есть мои LiveDataCallAdapterFactory и LiveDataCallAdapter 

class LiveDataCallAdapterFactory : Factory() {
    override fun get(
        returnType: Type,
        annotations: Array<Annotation>,
        retrofit: Retrofit
    ): CallAdapter<*, *>? {
        if (getRawType(returnType) != LiveData::class.java) {
            return null
        }
        val observableType = getParameterUpperBound(0, returnType as ParameterizedType)
        val rawObservableType = getRawType(observableType)
        if (rawObservableType != ApiResponse::class.java) {
            throw IllegalArgumentException("type must be a resource")
        }
        if (observableType !is ParameterizedType) {
            throw IllegalArgumentException("resource must be parameterized")
        }
        val bodyType = getParameterUpperBound(0, observableType)
        return LiveDataCallAdapter<Any>(bodyType)
    }
}


class LiveDataCallAdapter<R>(private val responseType: Type) :
    CallAdapter<R, LiveData<ApiResponse<R>>> {

    override fun responseType() = responseType

    override fun adapt(call: Call<R>): LiveData<ApiResponse<R>> {
        return object : LiveData<ApiResponse<R>>() {
            private var started = AtomicBoolean(false)
            override fun onActive() {
                super.onActive()
                if (started.compareAndSet(false, true)) {
                    Log.d("TAG", ": onActive Started ");
                    call.enqueue(object : Callback<R> {
                        override fun onResponse(call: Call<R>, response: Response<R>) {
                            Log.d("TAG", ":    $response");
                            postValue(ApiResponse.create(response))
                        }

                        override fun onFailure(call: Call<R>, throwable: Throwable) {
                            Log.d("TAG", ":    ${throwable.localizedMessage}");
                            postValue(ApiResponse.create(throwable))
                        }
                    })
                }
            }
        }
    }
}

Есть мой NetworkBoundResourse (работа только с Сетью) 


abstract class NetworkBoundResource<RequestType> {

    private val result = MediatorLiveData<Resource<RequestType>>()

    init {
        setValue(Resource.loading(null))
        fetchFromNetwork()
    }

    @MainThread
    private fun setValue(newValue: Resource<RequestType>) {
        if (result.value != newValue) {
            result.value = newValue
        }
    }

    private fun fetchFromNetwork() {
        val apiResponse = createCall()
        result.addSource(apiResponse) { response ->
            result.removeSource(apiResponse)

            when (response) {
                is ApiSuccessResponse -> {
                    setValue(Resource.success(processResponse(response)))
                }

                is ApiErrorResponse -> {
                    onFetchFailed()
                    setValue(Resource.error(response.errorMessage, null))

                }
            }
        }
    }

    protected fun onFetchFailed() {
    }

    fun asLiveData() = result as LiveData<Resource<RequestType>>

    @WorkerThread
    protected open fun processResponse(response: ApiSuccessResponse<RequestType>) = response.body

    @MainThread
    protected abstract fun createCall(): LiveData<ApiResponse<RequestType>>
}

Мой класс репо 


@Singleton
class AuthApiRepo @Inject constructor(
    val apiService: BrizSmartTVService
) {

    fun authLoginPass(login: String, password: String): LiveData<Resource<AuthResponse>> {
        return object : NetworkBoundResource<AuthResponse>() {

            override fun createCall(): LiveData<ApiResponse<AuthResponse>> {
                val authLogPassBody = AuthLogPassBody(login,password,"password")
                Log.d("TAG", ":   $authLogPassBody");
                return apiService.authLoginPass(authLogPassBody)
            }

        }.asLiveData()
    }
}

И мой класс AuthResponse 


class AuthResponse {
    @SerializedName("token_type")
    var tokenType: String? = null
    @SerializedName("access_token")
    var accessToken: String? = null
    @SerializedName("refresh_token")
    var refreshToken: String? = null
    @SerializedName("user_id")
    var userId: String? = null
    @SerializedName("expires_in")
    var expiresIn: Long = 0
    @SerializedName("portal_url")
    var portalUrl: String? = null
}

Мой класс ViewModel, откуда я начинаю звонить 


class AuthViewModel @Inject constructor(private val authApiRepo: AuthApiRepo) : ViewModel() {

    private var _isSigned = MutableLiveData<Boolean>()
    val isSigned: LiveData<Boolean>
        get() = _isSigned


    fun signIn(login: String, password: String) {
        authApiRepo.authLoginPass(login, password)
        val authRespons =  authApiRepo.authLoginPass(login, password)
        Log.d("TAG", ":   " +   authRespons.value.toString());
        //here will by always data null and status LOADING
    }

    override fun onCleared() {
        super.onCleared()
    }
}

1 Ответ

0 голосов
/ 20 апреля 2019

Итак, ребята, наконец я нашел решение.Это очень просто для людей, имеющих опыт работы с MVVM (живые данные), но я новичок в MVVM, и мой мозг взорвался, когда я пришел к этому.Итак, проблема заключалась в том, что я подписался на репо Ливата из ViewModel, а не из View (фрагмент в моем случае).После того, как я заблокировал цепочку наблюдателей liveata View - ViewModel - Repo - Service - все заработало.Спасибо всем

...