Size: a a a

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

2020 June 07

S

Singular in ReactiveX - русскоговорящее сообщество
Aleksey D.
ApiRequest.service.getItems()
 .subscribeOn(iSchedulerProvider.io())


ну и это вынести в отдельное что-то
Тестить Rx который возвращяет наблюдатель я умею. А вот меотд который void возращяет, с этим загвоздка. Статью прочитал, все равно не понял как тестить сам метод. Мокито это ад какой - то
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
Singular
Тестить Rx который возвращяет наблюдатель я умею. А вот меотд который void возращяет, с этим загвоздка. Статью прочитал, все равно не понял как тестить сам метод. Мокито это ад какой - то
такова жизнь. либо делаешь так, что тестировать надо что-то, что метод возвращает, либо извращаться с мокито
источник
2020 June 08

ЕС

Елена Сверидова... in ReactiveX - русскоговорящее сообщество
Всем не жадным приветик. Мне 18 лет, но я очень люблю шалить, покажу себя обнаженной и какие игрушки люблю. С удовольствием сделаю скидочку, и покажу всё на что способна😇😽
источник

Y

Yaroslav in ReactiveX - русскоговорящее сообщество
Елена Сверидова
Всем не жадным приветик. Мне 18 лет, но я очень люблю шалить, покажу себя обнаженной и какие игрушки люблю. С удовольствием сделаю скидочку, и покажу всё на что способна😇😽
/spam
источник

ЕС

Елена Сверидова... in ReactiveX - русскоговорящее сообщество
Всем не жадным приветик. Мне 18 лет, но я очень люблю шалить, покажу себя обнаженной и какие игрушки люблю. С удовольствием сделаю скидочку, и покажу всё на что способна😇😽
источник

N

Nixon in ReactiveX - русскоговорящее сообщество
Всем привет. Подскажите, что не так с этой цепочкой? subscribe не выводит TASK_COUNT, хотя TASK_NAME выводится в логи.
listObservable
               .subscribeOn(Schedulers.io())
               .flatMap(Observable::fromIterable)
               .filter(task -> {
                   Log.d("TASK_NAME", task.getName());
                   Log.d("TASK_ACTIVE", String.valueOf(task.isActive()));
                   return task.isActive();
               })
               .toList()
               .toObservable()
               .observeOn(AndroidSchedulers.mainThread())
               .subscribe(taskList -> Log.d("TASK_COUNT", String.valueOf(taskList.size()))
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
Nixon
Всем привет. Подскажите, что не так с этой цепочкой? subscribe не выводит TASK_COUNT, хотя TASK_NAME выводится в логи.
listObservable
               .subscribeOn(Schedulers.io())
               .flatMap(Observable::fromIterable)
               .filter(task -> {
                   Log.d("TASK_NAME", task.getName());
                   Log.d("TASK_ACTIVE", String.valueOf(task.isActive()));
                   return task.isActive();
               })
               .toList()
               .toObservable()
               .observeOn(AndroidSchedulers.mainThread())
               .subscribe(taskList -> Log.d("TASK_COUNT", String.valueOf(taskList.size()))
listObservable никогда не кончается.
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
Замени на Observable.just и проверь
источник

N

Nixon in ReactiveX - русскоговорящее сообщество
Понял, спасибо
источник

I

Ivan in ReactiveX - русскоговорящее сообщество
Что-то не пойму. Разве нельзя сделать так?

fun a(): Single<MyType> {
 return single
   .flatMap {
     if (foo == bar)
       Single.just(MyType())
     else
       Single.error(..)
   }
}

Т.е. во flatMap прокинуть Single.error нельзя? Нужно именно MyType?
источник

AA

Andrey Akimov in ReactiveX - русскоговорящее сообщество
Ivan
Что-то не пойму. Разве нельзя сделать так?

fun a(): Single<MyType> {
 return single
   .flatMap {
     if (foo == bar)
       Single.just(MyType())
     else
       Single.error(..)
   }
}

Т.е. во flatMap прокинуть Single.error нельзя? Нужно именно MyType?
так у тебя метод возвращает Single<MyType>, как ты хочешь вернуть что-то другое?
источник

I

Ivan in ReactiveX - русскоговорящее сообщество
Andrey Akimov
так у тебя метод возвращает Single<MyType>, как ты хочешь вернуть что-то другое?
я хочу ошибку бросить в определённом случае
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
хз, Single.error имеет тип T возращаемой функции т.е. параметизируется типом флэтмапа
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
Всегда так делал и все было норм
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
Попробуй принудительно дать ему тип
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
Но мне кажется либо я чего-то не понимаю в котлине либо у тебя идея глючит
источник

I

Ivan in ReactiveX - русскоговорящее сообщество
Артем Кулик
Всегда так делал и все было норм
+
источник

I

Ivan in ReactiveX - русскоговорящее сообщество
Артем Кулик
Но мне кажется либо я чего-то не понимаю в котлине либо у тебя идея глючит
реально что-то было с Андроид Студио. сейчас тот же код уже не подсвечивается
источник