Вопросы по теме 'rx-kotlin'
Выражение супердженериков в функциональных типах Kotlin?
Я пытаюсь портировать библиотеку RxJava и использовать функции расширения в Kotlin.
fun <T,R: MutableCollection<T>> Observable<T>.collectWhile(factory: (() -> R), condition: (R,T) -> Boolean) =...
846 просмотров
schedule
24.08.2022
Рекомендации по обработке исключений RuntimeException
Предполагается, что RuntimeExceptions указывает на ошибку программирования, и я хочу, чтобы мое приложение вылетало, когда что-то внутри моих наблюдаемых выдает RuntimeException.
Как лучше всего это сделать? Вот сейчас обдумываю это решение (это...
1339 просмотров
schedule
04.02.2023
Повторить отправку объекта подписчику на Rx
можно ли повторно отправлять один и тот же объект подписчикам в Rx? Например, этот код (на Котлине):
val exmp = listOf("А")
var observable = exmp.toObservable()
observable.subscribeBy(
onNext = {...
208 просмотров
schedule
16.08.2022
Как уведомить Observable, когда CountdownTimer завершится
У меня есть собственный Android TextView, который показывает количество времени, оставшееся в игре, через CountDownTimer.
class CountdownTextView(context: Context, attrs: AttributeSet) : TextView(context, attrs) {
private lateinit var...
902 просмотров
schedule
07.09.2022
onNext() никогда не вызывается для PublishSubject
Я пытаюсь создать презентатор, который вычисляет некоторые события в течение некоторого периода времени, показывает загрузку только при первой загрузке и обновляет пользовательский интерфейс, когда это делается. Поскольку события могут быть обновлены...
3054 просмотров
schedule
19.07.2022
Асинхронный вызов для каждого элемента в коллекции
У меня есть проблема, которую я не смог решить до сих пор, я новичок в RxKotlin, так что это может быть легко. Пожалуйста, взгляните на код:
override fun infos(): Stream<Info> =
client.infoAboutItem(identifier)...
404 просмотров
schedule
24.01.2023
Kotlin объединяет два изменяемых списка с нулевым значением
val mutableList1: MutableList<TeamInvitationData?>?
val mutableList2: MutableList<TeamInvitationData?>?
Метод addAll можно использовать для объединения изменяемого списка с нулевым значением, но здесь он выдает ошибку времени...
18791 просмотров
schedule
12.12.2023
RxSwift как Actions для Android
Впервые я познакомился с реактивным программированием с помощью ReactiveCocoa несколько лет назад. Там у них было понятие RACCommand s, которое было перенесено в RxSwift с библиотекой расширений Действие .
Как указано на их странице GitHub:...
585 просмотров
schedule
03.06.2022
Kotlin, как можно повторить запрос, если возникает ошибка при нажатии на кнопку диалогового окна
Давайте представим ситуацию на Kotlin, когда мы пытаемся получить запрос, но не имеем подключения к Интернету и получаем ошибку, затем показываем AlertDialog, и нам нужно повторить запрос, если пользователь нажмет «положительную кнопку».
Этот метод...
726 просмотров
schedule
31.03.2023
Сгладить Observable из Observables
Я хотел бы создать функцию, которая каждую секунду запускает другую функцию. Вторая функция возвращает Observables<A> , и я хочу, чтобы первая функция также возвращала Observables<A> вместо Observable<Observable<A>>...
291 просмотров
schedule
04.01.2023
Как разобрать ниже данные Json в Котлине?
Мне нужно разобрать эту информацию-
[
{
"artist": "12",
"image": "23"
},
{
"video_id": "12",
"video_title": "23"
},
{
"video_id": "12",
"video_title": "23"
},
{
"video_id": "12",
"video_title": "23"
},
{...
9569 просмотров
schedule
30.12.2022
Как добавить тело в URL в запросе Volley в Котлине?
Вот мой код для запроса залпа: -
val searchRequest = object : JsonArrayRequest(Request.Method.GET,url,
Response.Listener { response ->
val result = response.toString()
},...
7598 просмотров
schedule
24.05.2023
Rxjava, combLatest с утечкой памяти RxTextView
Я пытаюсь использовать combLatest с несколькими RxTextViews, и я думал, что правильно распоряжаюсь своими Disposables, но похоже, что у меня все еще возникает утечка памяти.
val one = RxTextView.afterTextChangeEvents(one)
val two =...
501 просмотров
schedule
07.04.2023
RXKotlin Break Inside doOnNext и вызов другой функции
Я использую rx kotlin недавно и еще не все понял. Я пытаюсь перебрать список запросов и выполнить их один за другим. в этом списке у меня есть специальная строка, которая когда-то была достигнута, я хочу разорвать цикл и выполнить другую функцию...
226 просмотров
schedule
01.09.2022
Создайте отфильтрованное наблюдаемое из 2 наблюдаемых списка элементов в RxJava
Я работаю над функцией, в которой мне нужно отфильтровать данные сетевого ответа на основе данных локальной базы данных.
Например, мои сетевые слои возвращают мне список элементов, а мой уровень базы данных возвращает наблюдаемый список...
82 просмотров
schedule
16.11.2022
Rx (RxKotlin) — rightGroupJoin с помощью groupJoin — слияние/объединение двух наблюдаемых разных типов
После нескольких дней борьбы над, казалось бы, простой задачей, я пришел к вам, ребята:)
Идея проста. У меня есть два потока/наблюдаемых: «левый» и «правый». Я хочу, чтобы элементы справа буферизировались/собирались/объединялись с текущим...
177 просмотров
schedule
12.07.2022
Модульный тест: Observer onChanged следует вызывать дважды, а не один раз
Почему при модульном тестировании ViewModel я получаю разные результаты?
У меня два теста. Когда я запускаю каждый тест по отдельности, это нормально, но когда я запускаю все тесты подряд, я получаю ошибку. Это ViewModel, состояние которого...
2497 просмотров
schedule
25.03.2023
основная функция мертва, пока работает rxjava. любое решение, пожалуйста
Я пытаюсь получить access_token с помощью RXjava.
Я запустил программу и вызвал функцию, которая запрашивает access_token, но процесс завершается с кодом 0.
Я думаю, что основной поток мертв при подключении к серверу
мое решение было...
49 просмотров
schedule
23.07.2022
RxKotlin объединяет последние более 9 полей
Я новичок в разработке Android, я пытаюсь выполнить проверку формы с помощью RxKotlin и RxBinding.
Мне нужно руководство, как сделать проверку формы с более чем 9 полями? На самом деле я могу объединить результат, используя...
254 просмотров
schedule
18.05.2023
Составление двух наблюдаемых источников с использованием одного в качестве предиката в RxJava
У меня есть 2 наблюдаемых источника, где fetchProductList() возвращает Observable<Datasource> , а другой canInvite.execute() принимает значение и возвращает Single<Boolean> . Мне нужно составить поток для передачи каждой эмиссии из...
153 просмотров
schedule
12.02.2023
