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
Создать ArrayList <String> из строки-массива ресурсов Как выбрать, какая перегрузка Java переопределить в производном классе Kotlin? Kotlin / Java функциональный и неизменный способ сбора карты на карте неразрешенная ссылка на класс, методы Android JUnit тест блокирует бесконечно, когда Observable наблюдается на AndroidSchedulers.mainThread () Доступ к информации из группы BroadcastReceiver в Android с использованием kotlin Как я могу использовать базу данных пользовательского интерфейса Firebase с Kotlin Почему «как» в Котлине не бросили в этом случае Kotlin HTML-Builder Как получить доступ к «Activity.this» в Котлине? В тесте kotlin укажите, как назначить lateinit var Что не так с использованием инсталляции setter для Android ViewModel против внедрения и ввода ViewModel.Factory? Это плохая практика поиска данных в списке по индексу несколько раз? Джексон не может десериализовать классы данных Котлина Недвижимость Котлина с геттером. Могу ли я указать начальное значение?