АК
подскажите как рестартануть single при succes с каким то условием?
например
single
.repeatIf{result -> result.name == "1"}
.subscribe{...}
например
single
.repeatIf{result -> result.name == "1"}
.subscribe{...}
Size: a a a
2020 April 22
АК
сейчам вот так делаю, но как то некрасиво
АВ
всем привет, подскажите есть такая цепочка,
Observable.interval(0, interval, TimeUnit.MILLISECONDS)
.flatMap(i -> rep.someRequest())
вопрос как мне сюда можно добавить что то типа булева сабжекта , который будет фильтровать дальнейшую работу? Кейс, есть кнопка которая включает или отключает работу получения данных с сервераАК
Можно не костыльным способом по “конпачке” отписываться (что будет правильно)
и не костыльным .filter(qqq -> !stop.get())
где stop - AtomicBoolean
и не костыльным .filter(qqq -> !stop.get())
где stop - AtomicBoolean
АК
Вторым способом я бы не делал)
АК
Но а так возможных вариаций множество
АК
Вы можете combine сделать из двух потоков и если значение второго вам не угодно - не запускать запрос
АВ
я делал unsubscribe, а после запускал цепочку снова, но почему то так не работало вовсе. + мне еще требуется интервал менять, который пользователь задаст. для меня очевидно было отписаться и заново подписаться с новыми вводынми . но чтото не взлетело
АК
значит что-то не так сделали:)
АВ
может, я засунул в
CompositeDisposable, и делаю dispose(), других вариантов не знаю)АК
например залезть в этот класс и посмотреть что делает метод dispose а что clear :)
АВ
спасибо, 🙈
АК
2020 April 23
K
Всем привет!
Подскажите, что-то не могу понять.
Делаю несколько запросов на сервер, как я могу игнорировать "неудачи" в запросах query(GetService(it))
Сейчас если один запрос неуспешен, то recentServices пустой
Подскажите, что-то не могу понять.
Делаю несколько запросов на сервер, как я могу игнорировать "неудачи" в запросах query(GetService(it))
Сейчас если один запрос неуспешен, то recentServices пустой
compositeDisposable.add(Completable.create {
recentServices.onNext(basket.getLastService().map {query(GetService(it)).blockingGet()})
}
.observeOn(AndroidSchedulers.mainThread())
.onErrorComplete()
.subscribe())2020 April 24
ND
А есть какой-нибудь combineLatest, но который бы эмитил не дожидаясь пока все стримы заэмитят?
АК
можно стартануть все стримы которые идут в комбайн с дефолтного значения
АК
startWith
ND
И действительно, спасибо