В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

ReactiveX - русскоговорящее сообщество

1025 membersпожаловаться на группу
2020 December 04

И

Игорь in ReactiveX - русскоговорящее сообщество
Evgeny GooDi
.take(1) берет первый элемент обсервабла, так? А что будет когда обсервабл получит новое значение?
Можете просто попробовать сэмулировать данный кейс с логам и - и вопрос отпадёт, но думаю может родится другой, но это уже будет после вашей самостоятельной попытки решить свой вопрос очень быстро
источник
22:50пожаловаться#1

И

Игорь in ReactiveX - русскоговорящее сообщество
А ещё можно просто тут глянуть, и вопрос вообще отпадёт - http://reactivex.io/documentation/operators/take.html
источник
23:01пожаловаться#2
2020 December 05

EG

Evgeny GooDi in ReactiveX - русскоговорящее сообщество
Игорь
А ещё можно просто тут глянуть, и вопрос вообще отпадёт - http://reactivex.io/documentation/operators/take.html
Насколько я понял после двух значений обсервабл выдаст онкомплит. Значит новые значения не будут приходить в оннекст. Если в качестве обсервабла использовать паблишсабджект, поведение то же?
источник
00:00пожаловаться#3

И

Игорь in ReactiveX - русскоговорящее сообщество
Evgeny GooDi
Насколько я понял после двух значений обсервабл выдаст онкомплит. Значит новые значения не будут приходить в оннекст. Если в качестве обсервабла использовать паблишсабджект, поведение то же?
Я же писал выше, берёшь эмулируешь логируешь, смысл вопросы задавать которые самому проверить можно?
источник
09:27пожаловаться#4
2020 December 14

S

Sergey in ReactiveX - русскоговорящее сообщество
Привет! А как в Single при получении ошибки, обработать ее, в случае если это нужная ошибка, вернуть определенное значение в этом Single заместо ошибки, а если отличные ошибки - то просто пропустить их дальше?
источник
15:13пожаловаться#5

S

Sergey in ReactiveX - русскоговорящее сообщество
Пробую onErrorReturn, но он требует вернуть именно значение, ошибку не получается
источник
15:13пожаловаться#6

S

Sergey in ReactiveX - русскоговорящее сообщество
А при onErrorResumeNext поведение странное, не такое как нужно..
источник
15:15пожаловаться#7

MC

Mikhail Chizh in ReactiveX - русскоговорящее сообщество
возможно doOnEvent тебе поможет
источник
15:16пожаловаться#8

S

Sergey in ReactiveX - русскоговорящее сообщество
Mikhail Chizh
возможно doOnEvent тебе поможет
При doOnEvent нельзя подменить ошибку на нужное значение((
источник
15:19пожаловаться#9

S

Sergey in ReactiveX - русскоговорящее сообщество
А если в onErrorReturn делать

throw new Exception(throwable)

Это нормально???
источник
15:20пожаловаться#10

S

Sergey in ReactiveX - русскоговорящее сообщество
Так вроде работает
источник
15:20пожаловаться#11

l

lenar in ReactiveX - русскоговорящее сообщество
Sergey
А если в onErrorReturn делать

throw new Exception(throwable)

Это нормально???
нет, не нормально
источник
15:35пожаловаться#12

A

Aleksandr in ReactiveX - русскоговорящее сообщество
lenar
нет, не нормально
Почему же доки гласят именно это?
https://github.com/ReactiveX/RxJava/wiki/Error-Handling-Operators#onerrorreturn
GitHub
Error Handling Operators
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM. - ReactiveX/RxJava
источник
15:35пожаловаться#13

l

lenar in ReactiveX - русскоговорящее сообщество
Sergey
А при onErrorResumeNext поведение странное, не такое как нужно..
через него. делаем проверку на тип ошибки и бросаем нужный обс - ошибку или поток
источник
15:36пожаловаться#14

A

Aleksandr in ReactiveX - русскоговорящее сообщество
или Вы к тому, что хотите сделать обработку не во время подписки?
источник
15:36пожаловаться#15

l

lenar in ReactiveX - русскоговорящее сообщество
Aleksandr
Почему же доки гласят именно это?
https://github.com/ReactiveX/RxJava/wiki/Error-Handling-Operators#onerrorreturn
GitHub
Error Handling Operators
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM. - ReactiveX/RxJava
в onErrorReturn не бросают ошибки через  throw. это делают через onErrorResumeNext
источник
15:40пожаловаться#16

A

Aleksandr in ReactiveX - русскоговорящее сообщество
Странно что в доке бросают ошибку именно через onErrorReturn
источник
15:40пожаловаться#17

S

Sergey in ReactiveX - русскоговорящее сообщество
lenar
в onErrorReturn не бросают ошибки через  throw. это делают через onErrorResumeNext
В документации тоже нашел такой пример, что бросается ошибка в onErrorReturn, но там бросается конкретная ошибка. А если мне просто передать ту что пришла нужно дальше... И только в одном случае вернуть элемент.
источник
15:43пожаловаться#18

S

Sergey in ReactiveX - русскоговорящее сообщество
lenar
в onErrorReturn не бросают ошибки через  throw. это делают через onErrorResumeNext
Попробую ещё раз с onErrorResumeNext, но он как-то странно выдает элементы... Вызвал  4 раза, выдал только один раз ошибку. А onErrorReturn вернёт 4 раза
источник
15:45пожаловаться#19

l

lenar in ReactiveX - русскоговорящее сообщество
single.onErrorResumeNext(thr -> thr instanceof IoException ? Single.error : Single.just)
источник
15:46пожаловаться#20