TestStore.java 文件源码

@Override
public Flowable<Optional<List<TestModel>>> getAll(final List<TestModel> items) {
    return getAll(null, null).map(new Function<Optional<List<TestModel>>, Optional<List<TestModel>>>() {
        @Override
        public Optional<List<TestModel>> apply(Optional<List<TestModel>> fullList) throws Exception {
            List<TestModel> output = new ArrayList<>();
            for(TestModel toFind : items){
                for(TestModel tm : fullList.get()){
                    if(tm.getId() == toFind.getId()){
                        output.add(tm);
                    }
                }
            }
            return Optional.wrap(output);
        }
    });
}