Articles of rx java2

Rxjava с kotlin

Я использую rxjava 2 в kotlin, но он не компилируется, как я должен его решить? var emailField = name.textChanges().skipInitialValue().toFlowable(BackpressureStrategy.LATEST) var passField = password.textChanges().skipInitialValue().toFlowable(BackpressureStrategy.LATEST) Flowable.combineLatest(emailField,passField, BiFunction { t1, t2 -> t1.isNotEmpty() && t2.isNotEmpty() })

Повторная установка 2, Rx 2 и асинхронные вызовы

Я только начинаю с Retrofit и Rx и создаю API-интерфейс улыбки с такой конфигурацией (Kodein): bind<CallAdapter.Factory>() with singleton { RxJava2CallAdapterFactory.create() } bind<RetrofitInterface>() with singleton { val retrofit = Retrofit.Builder() .client(instance()) .baseUrl(instance<String>("apiRoot")) .addCallAdapterFactory(instance()) .addConverterFactory(instance()) .build() retrofit.create(RetrofitInterface::class.java) } Теперь кажется, что когда я вызываю методы API, созданные Retrofit, они подписываются на текущий поток, а не на поток, […]

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

Вот моя цель: собрать ответы от асинхронных задач, которые поступают из сторонней библиотеки Требование: используйте RxJava2 для выполнения в порядке Я застрял в мысли, что я использую оператора или операторов для этого, идеи приветствуются. Моя мысль такова: Flowable.fromIterable(list) .anOperatorCanOnNextTheResponse() .buffer() .subscribe(newList)

Объединяемые зависимые наблюдаемые

У меня есть два Observable s, которые генерируют один и тот же тип данных. Но оба они зависят от последнего значения, испускаемого другим для оператора сканирования в качестве начального значения. Мне нужно объединить их. Я не могу сделать подписку на другую, потому что мои Observable s запускаются разными значениями. Я думаю, что темы должны быть […]

RxJava2: onComplete не вызывается с flatMapIterable

Вот короткий фрагмент кода: val subject = BehaviorSubject.createDefault(emptyList<Int>()) subject.onNext(Arrays.asList(1, 2, 3)) subject.flatMapIterable { list: List<Int> -> list } .subscribeBy( onNext = { l("on next", it) }, onComplete = { l("on complete") } ) Почему onComplete здесь не звонит? Что я должен сделать для работы с этим кодом? Потому что в исходном коде я не могу […]

Как использовать rxjava2 с модификацией в android

Привет, я пытаюсь изучить rxjava2. Я пытаюсь вызвать API с помощью rxjava2 и использовать модификацию для создания URL-адреса и преобразования JSON в Moshi. Я хочу использовать шаблон Observable с retrofit . Кто-нибудь знает, как это сделать? Любой стандартный и лучший подход, например, обертка для обработки ошибок и всех? AppModule.kt @Provides @Singleton fun provideRetrofit(moshi: Moshi, okHttpClient: […]

Загрузка файла с удаленного устройства и сохранение его на устройстве Android

То, что я пытаюсь сделать, – это разделить загрузку файла с того места, где я сохраняю его, например, в хранилище. Код, который отлично работает: Следующий код загружает файл с удаленного компьютера и, наконец, сохраняет его в хранилище. private fun downloadFile(url: URL): Observable<Int> { return Observable.create(fun(emitter) { var input: InputStream? = null var output: OutputStream? = […]

Выполнение Observable.fromCallable () с исключением

Я пытаюсь выполнить функцию, которая генерирует исключения. Observable.fromCallable { foo() } .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .take(1) .onErrorReturn { /* onError operation */ } .subscribe { } и я хочу сделать некоторые другие операции, если это удастся без каких-либо ошибок. Как я могу это сделать?

Цепочка Наблюдения, чтобы избежать нескольких подписок

У меня есть некоторые проблемы с цепочкой этих наблюдаемых. У меня есть func1() который выдает исключение при func1() . В onError меня есть func2() который выполняет выборку базы данных и func3() которая сохраняет базу данных путем изменения извлеченного документа. Как я могу связать это, чтобы избежать нескольких подписки? Observable.fromCallable { func1() } .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .take(1) […]

Облицовка проблем с реализацией Rx Java с архитектурой потока в kotlin android

Я внедряю flux-архитектуру в kotlin и пытаюсь использовать RX java в ней. Я создал диспетчер, который используется для отправки события и прослушивания событий Dispatcher.kt class Dispatcher @Inject constructor() { private val mBus:Subject<Any> init{ mBus = PublishSubject.create() } fun <A : IEvent> dispatchUserEvent(@NonNull e:A) { mBus.onNext(e) } fun <E : IEvent> observeUserEvents(clazz:Class<E>):Observable<E> { return mBus.ofType(clazz) } […]

Intereting Posts
Как добавить плагин Kotlin для Gradle в Android Studio 3.1 Canary 3 Используя Anko SQLLite, как лучше всего проверить, существует ли база данных? kotlin, Как значение действительной переменной мы можем изменить в другом классе, к которому она передала параметр? Почему первое вычисление в приложении для Android медленное, а все последующие вычисления быстры Идентификация Котлина не работает должным образом Как расширить класс класса Kotlin или использовать общие для создания простого свойства getter, который будет работать во всех подклассах Number? Как получить доступ и передать параметры модулям Android Instant App Котлинское преобразование объектов в объекты Как организовать файлы ресурсов макета в Android Studio? Неопределенная ошибка ссылки при вызове метода add в интерфейсе Kotlin Set Kotlin получает тип как строку Включить и отключить трансляцию в kotlin FusedLocationProviderClient С сервисом Android Kotlin Предоставлять насмешливый объект другому конструктору конструктивного объекта? Есть ли лучший способ получить доступ к свойствам с возможностью NULL?