Articles of rx java2

Введите собственные значения в combinelatest

У меня этот combinelatest текучий: private val subject: BehaviorSubject<Int> = BehaviorSubject.create() Flowable.combineLatest( materialA, materialB, subject.toFlowable(LATEST), Function3 { ma, mb, index -> if(index == 0) … else if(index ==1) … else … } subject.onNext(99) В принципе, я хочу наблюдать изменения db на обоих этих материалах и комбинировать их, чтобы показать пользователям некоторые данные. Иногда мне нужно […]

Создайте текущую функцию генерации с помощью RxJava2

Мне нужно создать настраиваемый Flowable с противодавлением. Я пытаюсь добиться своего рода подкачки. Это означает, что когда нисходящий поток запрашивает 5 элементов, я «спрошу источник данных» для пунктов 0 – 5. Затем, когда нисходящий поток нуждается в еще 5, я получу пункты 5 – 10 и вернусь обратно. Самое лучшее, что я нашел до сих […]

RxJava отличается от Flowable и Observable с помощью Window и Groupby

Я использую RxJava2 с кодом, который сводится к чему-то вроде этого: val whitespaceRegex = Regex("\\s+") val queryRegex = Regex("query=([^&]+)", RegexOption.IGNORE_CASE) val dateTimeFormatter = DateTimeFormatter.ISO_OFFSET_DATE_TIME @JvmStatic fun main(args: Array<String>) { val cnt = AtomicLong() val templateStr = "|date| /ignored/ query=|query|" val random = ThreadLocalRandom.current() var curDate = ZonedDateTime.of(LocalDate.of(2016, Month.JANUARY, 1), LocalTime.MIDNIGHT, ZoneId.of("UTC")) val generator = Flowable.generate<String> […]

Как исправить ошибку вывода типа в Completed, преобразованную с помощью RxLifecycle.bindToLifecycle ()?

Я использую Kotlin и RxJava2. Он отлично работает в других типах, например Observable и т. Д., Но когда я использую тип Completable, он дает мне ошибку вывода типа: type inference failed: Not enough information to infer parameter T in fun <T> bindToLifecycle(): LifecycleTransformer<T> Please specify it explicitly Вот код, который я использую: viewModel .updateText(returnedText) // […]

Компоненты архитектуры Android Room ViewModel CompleteableFormAction

Поэтому я подумал, что попробую « Room на небольшом побочном проекте. Я следовал примеру Флорины Мунтенеску: компоненты андроидной архитектуры Я уделяю особое внимание классам: UserActivity.kt , UserViewModel.kt , UserDao.kt UserViewModel#updateUserName() возвращает Completable и должен быть подписан на возврат onComplete или onError Когда я пытаюсь поместить свой эквивалент viewModel.updateUserName(userName) в цепочку RxBindings . Если я подпишусь […]

Kotlin: как преобразовать тест, который использует Thread.sleep для RxJava TestScheduler

Я пишу инструментальный тест, он проверяет, когда я кешу что-то в буфер Rx и через некоторый интервал (10 секунд) этот предмет вставляет буферизированные значения в мою базу данных Room. Тест правилен, когда я использую Thread.sleep (syncTimeInterval). Я хочу написать этот же тест с помощью TestScheduler. Здесь это версия Thread.sleep (которая проходит тест): @Test fun testMultipleLogs() […]

Ошибка возврата в Single

У меня есть метод: override fun signIn(userName: String, password: String): Single<User> { return userRemoteDataStore.signIn(userName, password) .map { mapper.mapFromEntity(it) } } Пользователь имеет два поля: username и error . Я хочу проверить, не является ли error поля нулевой. Я хочу вернуть эту ошибку. В этом случае я всегда получаю onSuccess. Как я могу это сделать?

Прослушивание сообщений и написание команд по наблюдаемому потоку

У меня есть метод, который открывает соединение ( Single<Connection> ) и другое, которое возвращает байты ( Observable<Byte> ), которые должны быть записаны в соединение при открытии: interface Connection { fun read(): Observable<Byte> fun write(command: Byte) } fun openConnection(): Single<Connection> // opens a single connection fun toBeWritten(): Observable<Byte> // output messages from elsewhere Проблема : я […]

Как скопировать список Завершенных исполнений с помощью RxJava?

У меня есть список BlockingTasks который я хочу запустить последовательно: class BlockingTaskManager { val tasks = mutableListOf<BlockingTask>() fun run () : Completable { /* What can I put here in order to run all tasks and return a completable according with the requirements described below? */ } } interface BlockingTask { fun run () : […]

как перебирать Single <List> и отображать в другой список?

в результате запроса на модификацию я получаю Single<List<Info>> Я должен перебирать каждый элемент и на основе каждого элемента id должен вызывать другой запрос, который также является Одиночным, а затем отображать в DetailInfo и в результате иметь Single<List<DetailInfo>> Я нашел flattenAsObservable и flattenAsFlowable, я не уверен, что это правильный подход, если да, у меня есть другая […]

Intereting Posts
Kotlin lateinit корреспондент java Как определить, является ли объект унаследованным от определенного класса в Котлине? Обновления / регенерации синтетического вида Android Studio Kotlin Kotlin & Vertx & Mongo: Как управлять функциями async CRUD? частный модификатор видимости и подпакеты Запуск контрольных тестов с значка игры в Android Studio запускает их как JUnit на JVM Котлин не смог преобразовать класс действия градиента в лямбда Kotlin AlarmManager и BroadcastReceiver не работают Передача приложения в AndroidViewModel Межстраничные объявления Admob: «IllegalStateException: только действия в полноэкранном режиме могут запрашивать ориентацию» Почему прокрутка ViewPager перед тем, как изменить его заполнение и pagemargin, полностью подвела его? Вывод лямбда-типа Java не работает должным образом в Котлине Kotlin и parallelStream toArray Что такое тест (0) в этом фрагменте от kotlinlang.org? Как перенести карту в андроид с помощью Kotlin