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
Android только setStackFromEnd, только если RecycleView / List больше экрана Как написать файл в Котлине? Kotlin использует утверждения времени выполнения для проверки нуля – служебные накладные расходы? как уменьшить размер видео во время записи, Android? Метод hasSystemFeature возвращает неправильное значение при проверке поддержки BluetoothLE NullPointerException в Android Studio 3 Beta 1 @StringRes, @DrawableRes, @LayoutRes и т. Д. Андроидные аннотации lint check с параметрами kotlin Ошибка Kotlin: Кинжал не поддерживает инъекцию в частные поля андроидные запросы с несколькими областями с помощью RXJava Ошибка выполнения сервлета Apache Tomcat, написанного в Котлине SugarORM + Kotlin: Неопубликованная ссылка "listAll" Kotlin: Как получить доступ к Attrs для CustomView Нельзя использовать значение argb color int в Kotlin? Откуда распространяются классы данных Kotlin? Могу ли я увеличить их? Объясните, почему показано предупреждение. Не отмечен ли источник-источник.readArrayList (data !!. JavaClass.classLoader) как ArrayList <Data>?