Spring 5.0 Cookbook

How to do it...

After using Reactor Core specification to build the service layer, let us apply Mono<T> and Flux<T> streams to @Controllers by doing these steps:

1. Open the ServiceController of the previous recipe again and add the following request handler showcasing the use of Reactor Stream operations:

@RequestMapping(value="/web/employeeNames.json", produces ="application/json", method = RequestMethod.GET, headers = {"Accept=text/xml, application/json"}) @ResponseBody public Callable<List<String>> jsonEmpNames(){ Callable<List<String>> task = new Callable<List<String>>() { @Override public List<String> call () throws Exception { List<String> names = new ArrayList<>(); System.out.println("controller:jsonEmpNames task executor: " + Thread.currentThread().getName()); ...