Телеграмм чат группы rxjavachat страница 22

вместо
return network.removeClaim(claimId, timestamp).map(v -> new DClaimEditingResult(0));

попробуй
return network.removeClaim(claimId, timestamp).cast(DClaimEditingResult.class).concatWith(Flowable.just(new DClaimEditingResult(0)));

16:09пожаловаться #1

вроде должно в итоге вернуть Flowable, который
- выполнит removeClaim
- отправит в onNext DClaimEditingResult(0)
- отправит onComplete

16:10пожаловаться #2

Дим, спасибо огромное, буду пробывать

16:18пожаловаться #3

Все работает, спасибо еще раз.

17:27пожаловаться #4

.cast() как я понял, преобразует или все элементы в определенный тип или он просто говорит, что дальше по цепочке будет такой тип данных?

17:45пожаловаться #5

Я думаю, он кастует все элементы
Но надо тестить

17:47пожаловаться #6

а чем отличается ompletable.fromAction() от ompletable.fromRunnable()?

18:06пожаловаться #7

Completable.

18:07пожаловаться #8

нашел, спс

18:08пожаловаться #9

ДФ

походу первый из Action а второй из потока))

18:08пожаловаться #10

лучше спрошу, раз такой разговор: detailsBox.remove(invoiceDetails) удаление всех элементов с Базы. Как из этого сделать Completable ?

18:14пожаловаться #11

ничего не возвращает, это void

18:14пожаловаться #12

сделать Callable<Void>
и юзать Completable.fromCallable

18:43пожаловаться #13

2017 July 24

Подскажите внутри Observable нужно запустить Countdown timer

10:50пожаловаться #14

а он меня посылает, говорит не могу создать

10:50пожаловаться #15

ДФ

Код в студию

10:54пожаловаться #16

https://gist.github.com/sergon146/fa92d0ed0618393499e5634fbb4c87d2

Gist

UdpService.java

11:03пожаловаться #17

ДФ

ошиба где именно ?

11:09пожаловаться #18

ДФ

если public void onTick(long l) выполняется ui потоке то там нельзя создовать socket

11:10пожаловаться #19

.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())