Articles of rx java2

RxJava2 Опубликовать

В чем разница между ObservableTransformer { Observable.merge( it.ofType(x).compose(transformerherex), it.ofType(y).compose(transformerherey) ) } а также ObservableTransformer { it.publish{ shared -> Observable.merge( shared.ofType(x).compose(transformerherex), shared.ofType(y).compose(transformerherey) ) } } когда я запускаю свой код с использованием этих двух, я получил те же результаты. Что делает публикация здесь.

Стоимость переключения потоков в RxJava и операции копирования класса данных Kotlin

Мой вопрос связан с расходами на операции, в частности, стоимостью операции copy() Kotlin) класса данных и переключением observeOn() RxJava observeOn() . У меня есть система, которая создает события, скажем, Schedulers.mainThread . События – это классы данных Kotlin . Далее идет бизнес-логика, и в итоге цепочка создает новый класс данных методом copy() . Все результаты должны […]

вызывать часть потока один раз с несколькими подписчиками?

У меня есть пользовательский адаптер Rx для связи сокетов. Вне этого я наблюдаю Flowable с сообщениями. Затем у меня есть менеджер, который обрабатывает каждое сообщение, а затем выделяет его дальше. fun observeSocket() = socketManager .observe() .doOnNext{ insideMessageHandler.handle(it) } Затем у меня есть два подписчика, которые наблюдают за Socket (). Subscribe () Проблема в том, что […]

RxJava Debounce onNext ()

Я пытаюсь отменить клики / прокрутки для моего коммутатора без успеха. Следующий код выглядит нормально, хотя onNext не проходит через debounce (), т.е.: когда пользователь спамет переключатель, onNext вызывается для каждого щелчка, не будучи опущенным из-за debounce. Он должен работать, это ошибка с RxJava? timer = Observable.create { subscriber: Subscriber<in Void>? -> super.setOnCheckedChangeListener { buttonView, […]

Преобразовать код RxJava в Kotlin правильно

Я изучаю как Котлин, так и RxJava. Я hava такой код в Java: public class MainActivity extends AppCompatActivity { private HashMap<String, Object> cacheToInsertToDb; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); cacheToInsertToDb = new HashMap<>(); Observable.interval(1, TimeUnit.SECONDS) .take(30) // up to 30 items .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Consumer<Long>() { @Override public void accept(Long aLong) throws Exception { […]

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

Я пытаюсь создать Observable, который будет генерировать новый объект каждую секунду. Поэтому на данный момент я просто застегиваю один Observable, который испускает конечное число объектов из списка с интервалом Observable. val list1 = mutableListOf<SomeClass1>( SomeClass1("1", 1), SomeClass1("2", 2), SomeClass1("3", 3), SomeClass1("4", 4), SomeClass1("5", 5), SomeClass1("6", 6), SomeClass1("7", 7), SomeClass1("8", 8), SomeClass1("9", 9) ) val someClass1Observable […]

Как получить последнее значение, исходящее из наблюдаемого

Предположим, у меня есть таймер, который испускает один элемент после одного интервала. Я хочу подписаться на него и выполнить его в течение 10 секунд. Через 10 секунд я отпишусь от него, а затем я хочу иметь доступ к его последнему присвоенному значению из какой-либо другой части кода. Вот пример кода: @Test fun testMeasuretime(){ val emitter […]

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

У меня есть такая функция: private fun enableSearch() { parentActivity?.let { parentActivity -> parentActivity.searchParamsObs //This is for the first time, to avoid having an empty trolley .flatMap { searchParams -> Observable.combineLatest(searchService.search(searchParams).toObservable(), orderItemsService.getCachedTrolleyOrRequest(), BiFunction<SearchResults, TrolleyItemsResponse, SearchListResultsAndTrolley> { searchResults, trolleyItems -> SearchListResultsAndTrolley(searchResults, trolleyItems) }) } .subscribeIO() .observeMain() .subscribe( { updateScreenWithSearch(it) }, { e -> onSearchError(e) }) .addTo(disposables) […]

Как имитировать излучение 2 infiite Наблюдаемые потоки и есть другие Observable, которые объединяют их и буферируют каждые 10 секунд?

Я хочу, чтобы иметь возможность имитировать слияние двух отдельных потоков, которые испускают некоторые объекты (которые расширяют один и тот же родительский объект), буферизуют их с помощью оператора буфера и испускают собранные данные через 10 секунд. Я хочу, чтобы этот механизм был бесконечным, таким образом, чтобы этот слияние / буфер всегда вызывался всякий раз, когда происходит […]

Странное поведение compose и ObservableTransformer в RxJava, когда переданный родословный расширяет что-то

Пытаясь сыграть с композицией в RxJava2, я нашел то, что я не могу объяснить. Предположим, что мы имеем следующие два статических метода: object RxUtils { fun <T> handleResponse(): ObservableTransformer<T, T> { return ObservableTransformer { observable -> observable.flatMap { t -> ObservableFromCallable.fromCallable(object: Callable<T>{ override fun call(): T { return t } }) } } } fun […]

Intereting Posts
Kotlin: Сделать внутреннюю функцию видимой для модульных тестов Анко не запускается Как Kotlin возьмет val как ключевое слово из класса java В чем причина twitter4j.StreamListner IllegalAccessError в Котлине? Kotlin: неоднозначность линейной лямбды и перегрузки Kotlin: возможно ли иметь постоянное свойство, зависящее от типичного типа реализации? Как найти поисковую панель на панели инструментов, например google? Представление календаря для создания представления Месяц, неделя и день с одним видом в Kotlin, Native Android и React-Native Получать размер процентного содержания Guideline в пикселях Вытягивание данных из API с помощью okHTTP и GSON BLE не может подключиться к уже подключенному устройству Возможно ли издеваться над аксессуарами от Mockito в Котлине? Соглашение об именовании котинов для логических методов возврата Быстрое наследование объектов и значение интерфейса Пытается запустить скрипт Kotlin в IntelliJ IDEA