У меня есть мои наблюдаемые, определенные следующим образом val initLoading = Observable.fromCallable { println("${System.currentTimeMillis()}") } .subscribeOn(Schedulers.computation()) .delay(WAIT_TIME,...

У меня есть сценарий, в котором у нас есть эмиттер, который постоянно выдает такие данные. fun subscribeForEvents(): Flowable<InkChannel> { return Flowable.create<InkChannel>({ if...

У меня есть два разных Observables, которые ведут себя как Наблюдаемое поведение -> Это будет создано, и один DisposableObserver будет подписан на него и будет реагировать на элементы, испускаемые Observable One. Это будет работать непрерывно,...

Я буду использовать исполнители потоков для выполнения некоторой фоновой работы с rxkotlin, я установил размер пула потоков равным 3, но моя проблема заключается в том, что во время моей фоновой операции он использует только один поток из 3, что...

Итак, я совершенно новичок в rx-java / rx-kotlin и не слышал об этом, пока не узнал, где написать HTTP-фильтр в Micronaut ( https://docs.micronaut.io/latest/guide/index.html#filters ), что застало меня врасплох, поскольку я делал только регулярные...