Всем привет. Подскажите, что не так с этой цепочкой? 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()))

два варианта: 1)ты их всех фильтранул. они все неактив; 2) поток событий бесконечен, toList не выполнится никогда

Второй вариант больше похож на правду. По какой причине такое может быть? Или причин может быть много?

это к тебе вопрос. что у тебя за источник вечный-бесконечный

Понял, спасибо за подсказку

При старте делается запрос в сеть. Как повторить этот же запрос по клику?

У презентера вызывай тот же метод.

https://github.com/LukasLechnerDev/Kotlin-Coroutine-Use-Cases-on-Android

У кого-нибудь есть такая же подборка по Rx?

о спасибо братик, годная тема для корутин

Други, наведите, плиз, на мысль, какими операторами пользоваться, чтобы отловить определенные источаемые элементы, идущие один за другим? Т.е. если приходит число 5, а затем 7, то выдать то-то

distinct - операторы могут подойти

Что-то не очень получается( Пытаюсь понять, как сделать, что если за 1 секунду пришло 5, затем 7, то их обоих вообще выкинуть, а если 5 и 8, до нормально и пропускать дальше...

всем привет, подскажите каким образом можно предать полученные данные в методе subscribe в другой класс?

Так в onSuccess ты получаешь данные, потом просто юзай их

Я не могу просто создать  переменную А, затем сохранить  данные  из onSuccess в созданную переменную А. Точнее я могу это сделать, но только вот за пределами метода onSuccess то  значение которое я присвоил в методе onSuccess теряется

Так ничего что он саксес это своего рода колбек? Только там надо обрабатывать данные. Если это мвп, то вызываются определенные методе вью стейта.

Я понимаю что это своего рода колбек, но я не могу просто так взять присвоить в переменную данные полученные из onSuccess и затем работать с этими данными в каком-нибудь другой части кода. А мне нужно получить данные из onSuccess и эти данные как-то передавать в метод который делает апи запрос

Ты хочешь в onSuccess еще раз в сеть сходить?

Нет, У меня есть отдельный класс в котором я получаю текущее местонахождение устройства, далее я обрабатываю полученные данные в rxjava и затем мне нужно передать полученные данные широты и долготы в мой ViewModel класс , в метод который делает апи запрос

Так а что мешает эти данные то тебе прокинуть куда надо то?