как добавить параллелизм для потока в весеннем веб-потоке - PullRequest
Новая
       47

как добавить параллелизм для потока в весеннем веб-потоке

0 голосов
/ 23 апреля 2020 
@Transactional
public Flux<Todo> createTodos(Flux<Todo> todos) {

        return todos.map(todo -> new TodoToEntityTransformer().apply(todo))
                .collectList()
                .map(todoEntities -> {
                    todoEntities = todoRepository.saveAll(todoEntities);
                    todoRepository.flush();
                    return todoRepository.findAllById(todoEntities.parallelStream().map(todoEntity -> todoEntity.getTodoId()).collect(Collectors.toList()));
                })
                .flatMapMany(Flux::fromIterable)
                .map(todoEntity -> new EntityToTodoTransformer().apply(todoEntity));
}

мы должны добавить параллелизм для этой топи c. кто-нибудь может мне помочь?

...