Articles of rx java2

Kotlin & Vertx & Mongo: Как управлять функциями async CRUD?

Друзья! Я – зеленая рука Веркса и Монго, теперь я столкнулся с трудной проблемой. Ниже приведены фрагменты кода. Вот класс оболочки Mongo Client. // MongoDatabase.kt import io.vertx.core.json.JsonObject import io.vertx.core.logging.LoggerFactory import io.vertx.kotlin.core.json.JsonObject import io.vertx.rxjava.core.Vertx import io.vertx.rxjava.ext.mongo.MongoClient import kotlin.reflect.KClass import kotlin.reflect.full.declaredFunctions class MongoDatabase<T: Any> (val tClass: KClass<T>, vertx: Vertx, config: JsonObject, databaseName: String) : Database<T> { private […]

Возможность аутентификации пользователя в режиме Firebase, но не может хранить данные в базе данных Firebase

Я могу аутентифицировать пользователя с помощью проверки Firebase, но не смог сохранить данные в базе данных Firebase. Я не получаю ошибок в logcat. Я не изменил никаких правил в базе данных Firebase. Мои правила установлены по умолчанию. Вот мой код: fun authenticateUser(){ Observable.create(ObservableOnSubscribe<Task<AuthResult>>{ e: ObservableEmitter<Task<AuthResult>> -> run { try { firebaseAuth.createUserWithEmailAndPassword(email!!, password!!) .addOnCompleteListener(this, object : […]

Как создать обработчик Generic Response для ошибки и проверки ответа с помощью модифицированных, rxjava и кинжалов

Я пытаюсь создать общую архитектуру для использования сложной структуры json следующим образом: Формат Json { "type": "success", "code": "s-groups-0006", "description": "Index List successfully", "result": { "asOnDate": 1505457095278, "indexList": [ { "change": "22.35", "changePercent": "0.27", "isDefault": true, "isEditable": false } ] } } Формат кинжала @Singleton fun provideGson(): Gson = GsonBuilder() .setLenient() // .registerTypeAdapter(BaseResponse::class.java, RestDeserializer<BaseResponse<T>>()) .create() […]

Как сигнализировать Observable для получения большего количества данных

Есть ли способ сигнализировать Observable для получения большего количества данных? У меня есть буферизированный Observable, который производит 10 элементов, и я хочу, чтобы он продолжал создавать больше предметов только тогда, когда захочу. Чтобы быть более конкретным, у меня есть бесконечный прокручиваемый Recycler View, я хочу создать больше предметов только тогда, когда я продолжу прокрутку до […]

андроидные запросы с несколькими областями с помощью RXJava

Я поддерживаю приложение, которое не сделал сам. Приложение работает на специальном устройстве Android, которое может считывать штрих-коды с использованием лазерного луча, и после ввода штрих-кода приложение начинает проверять через lal базы данных Realms, если такой код существует, дело в том, что поисковых запросов много, потому что приложение должно ищите все мелкие буквы и все заглавные […]

Дополнительные наблюдаемые данные в combLatest

Как определено, combLatest в rx emites только если все значения изменились хотя бы один раз. (до тех пор, пока каждая из исходных наблюдателей испускает хотя бы один элемент) Я использую его для манипулирования представлениями в своих представлениях Android. Например, я включаю кнопку вызова к действию, как только все наблюдаемые выдают действительное значение. В противном случае […]

RxJava Subject: Слушайте другой тип, который тот, который он испускает

Я провоцировал события цепочек Rx, и у меня проблемы с получением того, что я хочу работать. Я в основном запрашиваю разрешение пользователя, запрашивая местоположение пользователя, если он был предоставлен, а затем запрашивает данные из API. Ниже приведен код из ViewModel и я хочу, чтобы мой View (технически Fragment ) прослушивался. Моя проблема с приведенным ниже […]

Миграция номера, попытка повторного открытия уже закрытого объекта: SQLiteDatabase

У меня простая база данных Singleton и miration_1_2, поэтому это простой, вероятный пример. Вы можете увидеть класс базы данных @Database(entities = [Feed::class, NewsWidget::class, NewsWidgetFeed::class], version = 2) abstract class Database : RoomDatabase() { abstract fun feedDao(): FeedDao abstract fun newsWidgetDao(): NewsWidgetDao abstract fun newsWidgetFeedDao(): NewsWidgetFeedDao companion object { @Volatile private var INSTANCE: com.example.Database? = null […]

Как начать второй наблюдаемый после получения результата от первого наблюдаемого в андроиде?

Я не понимаю, как использовать результат первого наблюдаемого во втором наблюдаемом. -> My First Observable var uploadImgObservable = Observable.create<File> {….} -> My Second Observable var thumbnailObservable = Observable.create<Task<UploadTask.TaskSnapshot>> {…} Теперь я хочу использовать результат uploadImgObservable в thumbnailObservable. Я также попытался использовать flatmap, как было предложено stackoverflow, но я не получил его. Вот как я использовал […]

ручка onKeyDown с использованием RxAndroid

Я использую https://github.com/mkoslacz/Moviper для своего приложения для Android Tv Box. Существует только одно действие с несколькими дочерними фрагментами. Я хочу распространять onKeyDown на дочерние фрагменты, только если событие еще не обработано. Это было легко обойтись без использования RxJava. Я мог бы возвратить логическое значение, чтобы сказать, что событие уже обработано или нет. Есть ли способ, […]

Intereting Posts
Querydsl – результат разделения на два или более объекта Рефакторинг моего класса зрителей в Котлине Почему я получаю: null не может быть применен к непустому типу android.widget.SearchView? Почему существует разница между сборщиками coroutine для CompletableFuture и ListenableFuture? Синтетическое расширение Котлина для просмотра Генераторы Kotlin: использование интерфейса для MVP Каков правильный способ создания экземпляра класса из KType Android ClassNotFoundException Не нашел класс на пути: DexPathList Как реализовать общую функцию интерфейса в Котлин? ExpandableListView не отображается в моей деятельности Есть ли какие-либо документы об модификаторах доступа в Котлин? Gradle Kotlin DSL: Определите версию Kotlin в уникальном месте Функцию можно написать в Котлине (т.е. на верхнем уровне). Могу ли я также тестировать те, кто находится на верхнем уровне? Поддерживается ли kapt в maven? Могу ли я использовать kotlin.reflect, чтобы получить значение поля