@DmitryOganezov, please, press the button below within the time amount specified, otherwise you will be kicked. Thank you! (60 sec)
Powered by Todorant

Всем привет! Ребят, помогите с идеями: пытаюсь разобраться с concatMap(). Задумка такая: есть список элементов, с каждым из которых нужно совершить некую длительную операцию и вывести ее результат (последовательно, очередность элементов важна).  Показалось, что concatMap() будет хорошим выходом. Проблема в том, что цепочка не ждет окончания inner observables внутри concatMap. Есть какое-нибудь элегантное решение?
https://www.jdoodle.com/a/2NtA

привет всем, начал только изучать rx, есть вопросы возможно вы  подскажите. Чисто для примера хочу в списке внести изменение как это можно добиться используя rx

Observable<String> observable = Observable
               .from(rst);

Observer<String> observer = new Observer<String>() {
           @Override
           public void onCompleted() {
               Log.d(TAG, "onCompleted");
           }

           @Override
           public void onError(Throwable e) {
               Log.d(TAG, "onError: " + e);
           }

           @Override
           public void onNext(String s) {
               s=s+"new";
               Log.d(TAG, "onNext: " + s);
           }
       };

// subscribe
       observable.subscribe(observer);
       for (String s : rst) {
           Log.i(TAG, "result " + s);
       }

возможно через оператор map,
где вы получаете одно значение, а выдаете другое

Mlago Rogers, please, press the button below within the time amount specified, otherwise you will be kicked. Thank you! (60 sec)
Powered by Todorant

@KurtCarri, please, press the button below within the time amount specified, otherwise you will be kicked. Thank you! (60 sec)
Powered by Todorant

Всем привет, подскажите может, кто знает, как решить https://ru.stackoverflow.com/questions/1230881/rxjava-%d1%80%d0%b0%d0%b1%d0%be%d1%82%d0%b0%d0%b5%d1%82-%d1%81-%d0%b7%d0%b0%d0%b4%d0%b5%d1%80%d0%b6%d0%ba%d0%be%d0%b9-%d0%bf%d0%be%d1%82%d0%be%d0%ba%d0%b0?noredirect=1#comment2156723_1230881

Ну так ты в каком потоке загружаешь?

.observeOn(AndroidSchedulers.mainThread())

Ну так мэйнтрэд надо заменить наверное)

там выбор заменить не велик, я пробовал на     .observeOn(AndroidSchedulers.from(activity.getMainLooper())) но тоже самое

Io ставь

тоже самое

здесь processing трудоемкий иетод так как выполняет тяжелые операции может другие операторы использовать

подними point = processing(file, save); до observeOn в оператор map. и computation лучше заменить на io

вряд ли опенсв чисто вычислительный. наверняка там есть блокирующие действия

спасибо получилось! получается processing блокировал observeOn? потому что когда observeOn был до метода processing он просто не работал, а сейчас работает все отлично