@SpringBootApplication
public class SpringWebReactiveApplication {
public static void main(String[] args) {
SpringApplication.run(SpringWebReactiveApplication.class, args);
}
@Autowired
UserRepository userRepository;
@PostConstruct
public void init() {
System.out.println("--------init start--------");
userRepository.saveAll(Flux.just(User.of("manolo", "manolo", "Spain"), User.of("manuel", "manuel", "Spain"), User.of("David", "David", "Spain"))).then();
userRepository.save(User.of("ana", "ana", "Spain")).then();
userRepository.saveAll(Mono.just(User.of("marta", "marta", "Spain"))).next();
System.out.println("--------init end--------");
}
}
I have tried some basic functionalities of Spring WebFlux, the reactive repository works fine with client requests like “DELETE”, “POST” etc.
It seems like that I cannot submit asynchronous tasks to the event loop queue outside of the webflux workflow as I tried in the previous code.