Rx Java Buffer - список списка - PullRequest
0 голосов
/ 17 марта 2020
public class RxBufferMasterList {

    private List<ArrayList<Integer>> mMasterList;
    RxBufferMasterList() {
        mMasterList = new ArrayList<ArrayList<Integer>>();
    }

    public void execute() {
        Observable.fromIterable(getList()).buffer(3).subscribe(new Observer<List<Integer>>() {
            @Override
            public void onSubscribe(@NonNull Disposable d) {
                Log.i("Reactive","onSubscribe");
            }

            @Override
            public void onNext(@NonNull List<Integer> integers) {
                Log.i("Reactive","onNext: "+integers);
                mMasterList.add((ArrayList<Integer>) integers);
            }

            @Override
            public void onError(@NonNull Throwable e) {
                Log.i("Reactive","onError: "+e.getMessage());
            }

            @Override
            public void onComplete() {
                Log.i("Reactive","onComplete: "+mMasterList);
            }
        });
    }

    private List<Integer> getList() {
        Integer[] intArray = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
        return Arrays.asList(intArray);
    }
}

Итак, я хотел бы избавиться от функциональности mMasterList.add. Я думаю, что можно получить список из самой Observable. Какой оператор следует использовать для этой цели?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...