Я пытаюсь создать пользовательскую функцию, которая будет обрабатывать все мои ответы API, но я не знаю, как правильно обрабатывать ее.
Это мой код
Мой пользовательский обратный вызов
interface ResponseCallback<T> {
fun onSuccess(response: T)
fun onError(code: Int, message: String)
}
Вот как я называю мой запрос API
createRequest(getLogin(id), object : API.ResponseCallback<LoginResponse>{
override fun onError(code: Int, message: String) {
}
override fun onSuccess(response: LoginResponse) {
}
})
, и именно так я обрабатываю свой запрос
fun createRequest(source: Observable<*>, callback: ResponseCallback<*>) {
disposable.add(
source.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
{ it ->
//
// callback.onSuccess(it)
},
{
}
)
)
}
, но моя проблема здесь в том, чтоcallback.onSuccess()
параметр Nothing
и не может принять callback.onSuccess(it)
Пожалуйста, помогите мне, спасибо.