Articles of rx java2

rxjava2 – простой пример выполнения задач в пуле потоков, подписывается на один поток

Я экспериментирую со следующей задачей, чтобы получить голову вокруг RxJava: Учитывая список URL-адресов Выполнять HTTP-запрос для каждого URL-адреса в пуле потоков Для каждого результата вставьте некоторые данные в базу данных SQLite (здесь нет многопоточности) Блокировать метод до его завершения Поэтому я попробовал это в Котлине: val ex = Executors.newFixedThreadPool(10) Observable.fromIterable((1..100).toList()) .observeOn(Schedulers.from(ex)) .map { Thread.currentThread().name } […]

Как я могу объединить одиночный <Список <Список <T >>> В список <T> с RxJava 2?

Я хочу сделать конечную точку, чтобы получить список пользователей, который возвращает Single<List<User>> . Затем я хочу захватить первых трех пользователей и нажать другую конечную точку, чтобы получить все свои сообщения. Single<List<Post>> . Наконец, я хочу отобразить Toast который имеет общее количество сообщений для всех первых 3 пользователей. Я смог добиться этого с помощью функции flatten() […]

Вызов RxJava Single In Kotlin Lambda

Я пытаюсь возиться с новой библиотекой Room, соединяя ее с RxJava. Я нашел способ использовать Single для вставки элементов в фоновый поток, как это, внутри действия: Single.fromCallable { AppDatabase.getInMemoryDatabase(this).taskDao().insertAll(task) } .subscribeOn(Schedulers.newThread()) .subscribe() Теперь у меня есть RecyclerView с задачами, у которых есть флажок, который вы можете использовать, чтобы пометить элемент как полный или нет. Я […]

Как продолжить обработку после ошибки в RxJava 2?

У меня есть PublishSubject и Subscriber которые я использую для обработки (возможно) бесконечного потока предварительно обработанных данных. Проблема в том, что некоторые элементы могут содержать некоторую ошибку. Я бы хотел проигнорировать их и продолжить обработку. Как я могу это сделать? Я пробовал что-то вроде этого: val subject = PublishSubject.create<String>() subject.retry().subscribe({ println("next: $it") }, { println("error") […]

Ошибка вывода Kotlin и RxJava

Я пытаюсь реализовать retryWhen на моем Observable, когда происходит тайм-аут, но у меня есть странные ошибки, подчеркнутые в IDE Android Studio 3.0 Вот код: rxRssiRepository.onRssiUpdate() //returns Observable<RssiEvent> .timeout(10, TimeUnit.MILLISECONDS) .retryWhen { t: Observable<Throwable> -> t.flatMap { error: Throwable -> if (error is TimeoutException) { stopLocationUpdates() Log.v("TIMEOUT", "TIMEOUT RSSI EVENTS") Observable.just(Observable.empty()) } else { Observable.error(error) } […]

Cant 'observOn' основная нить с RxKotlin

Я пытаюсь наблюдать наблюдаемые в основной теме, используя: // Kotlin Code Observable .observeOn(AndroidSchedulers.mainThread()) но я получаю следующую ошибку: Type Mismatch: Required: rx.Scheduler! Found: io.reactivex.Scheduler! Наблюдаемый, на который я подписался, является библиотекой, написанной на Java, и поэтому использует RxJava. Неужели я глуп и что-то не хватает? Я озадачен: $ Заранее спасибо 🙂

Почему моя установка RxJava блокирует мой поток пользовательского интерфейса? Работа с обратным вызовом BluetoothAdapter.startLeScan

Я пытаюсь найти конкретное действие, которое блокирует мой поток пользовательского интерфейса, я пробовал несколько операторов планировщика, но я не уверен, как заставить его работать. У меня есть пользовательский интерфейс с кнопкой, который onClicked запускает сканирование bluetooth и обновляет textView со строками, такими как журнал (он показывает, что происходит в данный момент). Итак, вот моя MainActivity: […]

Преобразование может быть в одиночку из другого источника, если возможно завершено

Я хотел бы создать класс Repository который возвращает Single<Something> . Сначала класс должен выглядеть в Cache который возвращает Maybe<Something> и если « Maybe завершается в мою Service которая возвращает Single<Something> interface Cache { fun getSomething(): Maybe<Something> } interface Service { fun getSomething(): Single<Something> } class Repository ( private val cache: Cache, private val service: Service […]

Kotlin не может вывести тип при использовании ссылки метода в Flowable

У меня этот код в Java: Flowable.just(1,2,3) .flatMap(Flowable::just); и этот код в Котлине: Flowable.just(1,2,3) .flatMap(Flowable::just) В то время как Java-код компилируется отлично, компилятор Kotlin говорит: «Ошибка: (47, 30) Kotlin: Один аргумент типа, ожидаемый для класса Flowable: Publisher, определенный в io.reactivex" Однако это компилирует штраф: Flowable.just(1,2,3) .flatMap { Flowable.just(it) } Что я делаю неправильно и почему […]

RxJava zipWith Ошибка IDE в Kotlin с использованием Android Studio 3.0

Я хочу создать Observable, который испускает некоторые элементы и Observable, содержащие список объектов с Interval Observable, так что элементы из первого наблюдаемого будут излучать с некоторой задержкой по времени. Вот моя реализация: val just1 = ArrayList<SomeClass1>() заполнять некоторые предметы fun populateJust1() { just1.add(SomeClass1("23", 23)) just1.add(SomeClass1("24", 24)) just1.add(SomeClass1("25", 25)) } populateJust1() и zip с интервалом Observable […]

Intereting Posts
Возможно ли, чтобы Java создала перегрузку метода с аргументами по умолчанию, такими как Kotlin? gradle не удается скомпилировать классы java с использованием класса kotlin В чем преимущества написания кода JavaScript с помощью Kotlin? Kotlin – println с использованием строкового шаблона для stderr Внедрение в Kotlin – метод Значение по умолчанию Как HashMap реализует интерфейс MutableMap в Котлине? Вызывающая (базовая) делегированная функция при использовании делегирования класса из переопределения @Inject set Not Injecting Property Как сохранить логотип над рушащейся панелью инструментов Доступ к типам параметров внешнего типа Имеет ли Kotlin эквивалент Unplicitly Unwrapped Optionals в Swift? Что является предпочтительным решением для Kotlin koan «Partition» и почему? Как динамически масштабировать отскок потока эмиссионных выбросов? Реализация Java-аннотации в Котлине IllegalArgumentException: savedInstanceState Указано как Non-Null Null