Ребят, привет!
У меня есть два Completable запроса
Как мне объединить их и подписаться на оба сразу?
Я слышал это делается с помощью zip, но я не совсем понимаю как
Помогите, пожалуйста🙏🏻

(RxSwift)

Completable.mergeArray, если он есть в рхсвифте

еще -3 и будет 1к

что делает реплэй и рефкаунт?

Самому интересно стало.
Replay(1) кэширует последнее пришедшее значение
refCount() не дает обзерваблу закрыться пока на не отпишутся все субскрумберы

спасибо. понял )

Мне казалось refCount не то что не даёт закрыться, а закрывает, когда не остаётся обзерверов

Имхо смысл тот же

Всем привет!
Скажите практический сколько может работать interval в rxJava? Если устройство 24/7 находиться на зарядке, и все время с активным экраном?

    fun periodicRequest() {
        addDisposable(
            Flowable.interval(Constants.SYNC_INTERVAL, TimeUnit.MILLISECONDS, Schedulers.io())
                .flatMap { requestToServer() }
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe()
        )
    }
    
    oveeride fun onDestroy() {
        getDisposable().clear()
    }

Добрый день.

Хотел уточнить пару вещей про project reactor.

Если у меня есть тред пул на условных 10 потоков и в нём я запускаю цепочку (в моём случае дергаю другой сервис через web client)

@JmsListener(…)
fun someMethod() {
val mono = someReactiveService.invokeReactiveClient()
mono.subscribe()
}

…

fun invokeReactiveClient(): Mono<Unit> {
return webClient.post().uri()…
}

То в таком случае у меня subscribe не заблочит текущий поток? Важно уточнить, что someMethod исполняется на тред пуле ActiveMQ очереди (10 потоков). Либо есть ли смысл делать тут блокировку цепочки через mono.block() ? И в чём отличие?

@JmsListener(…)
fun someMethod() {
val mono = someReactiveService.invokeReactiveClient()
mono.subscribe()
}

…

fun invokeReactiveClient(): Mono<Unit> {
return webClient.post().uri()…
}

subscribe будет на потоке stream-a (а он на своем потоке) и получается он не блочит поток mq. а вот сделав block ты заблочишь именно поток mq, чтобы он ожидал завершения стрима

Подскажите почему тут onComplete не передается в основную цепочку. showMessages() не вызывается.

…
.flatMapCompletable {
   fetchMessages()
}
.andThen {
    showMessages()
}

fun fetchMessages() = api
  .getSingle()
  .doOnSuccess { … }
  .ignoreElement()

Но если напишу так, то отрабатывает:
…
.flatMapCompletable {
   fetchMessages().andThen {
             showMessages()
        }
}

Это я тут затупил. Там выше, перед flatMapCompletable вызывался repeat, который возвращал Flowable. И естественно andThen не вызывался, потому что поток (Flow) не завершается сразу же после первого элемента.

Всем привет. Друзья, кто подскажет способ сделать цепочку, чтобы подписчик выполнял callback с первого emit'а имея pairwise? Пускай previousValue будет null.

Со startWith() в начале цепи работает.

библиотеки: rxjava3, room 2.2

DAO
   @Insert(onConflict = OnConflictStrategy.REPLACE)
   fun insertPostItem(item: PostItem): Completable

Ошибка: Not sure how to handle insert method's return type

Ребята, подскажите что я не так делаю, пожалуйста

Пишут что только с room 2.3.0-alpha02 добавили поддержку rxJava3
https://developer.android.com/jetpack/androidx/releases/room#2.3.0-alpha02

Здравствуйте, подскажите как можно собрать все exceptions с observable?
То есть нужно чтобы источник не прекращал выдавать данные даже после эксепшна. Он должен продолжить дальше выдавать данные   и при этом мы смогли эти эксепшины потом получить как список

Интересует как это сделать с помощью rx, если так можно конечно