Example usage of reactor-data with Spring Boot

TradeController.java

@Controller
public class TradeController {

  @Autowired
  private ClientComposableRepository clients;

	@RequestMapping(value = "/{clientId}", method = RequestMethod.POST)
	@ResponseBody
	public DeferredResult<String> trade(@PathVariable Long clientId) {
		final DeferredResult<String> d = new DeferredResult<String>();

		clients.save(clients.findOne(clientId)
		                    .map(new Function<Client, Client>() {
			                    public Client apply(Client cl) {
				                    return cl.setTradeCount(cl.getTradeCount() + 1);
			                    }
		                    }))
		       .map(new Function<Client, String>() {
			       public String apply(Client cl) {
				       return "Hello " + cl.getName() + "! You now have " + cl.getTradeCount() + " trades.";
			       }
		       })
		       .consume(new Consumer<String>() {
			       public void accept(String s) {
				       d.setResult(s);
			       }
		       });

		return d;
	}

}

TradeControllerJava8.java

@Controller
public class TradeController {
 
  @Autowired
  private ClientComposableRepository clients;
 
  @RequestMapping(value = "/{clientId}", method = RequestMethod.POST)
  @ResponseBody
  public DeferredResult<String> trade(@PathVariable Long clientId) {
  	final DeferredResult<String> d = new DeferredResult<>();
  
  	clients.save(clients.findOne(clientId)
  	                    .map(cl -> cl.setTradeCount(cl.getTradeCount() + 1)))
  	       .map(cl -> "Hello " + cl.getName() + "! You now have " + cl.getTradeCount() + " trades.")
  	       .consume(d::setResult);
  
  	return d;
  }
 
}

Indent issue? Also may be use constructor injection to minimise mutability easier to test too. :-)

How about a Scala sample? :-)