Reactive controller

Controller.java

@RestController
@RequestMapping("/reactive")
public class Controller {

    private final R2DBCSubscriptionRepository userRepository;

    @Autowired
    public Controller(R2DBCSubscriptionRepository userRepository) {
        this.userRepository = userRepository;
    }

    @GetMapping("user/{id}")
    public Mono<User> get(@PathVariable long id) {
        return userRepository.findById(id);
    }

    @PostMapping("user")
    public Mono<User> add(@RequestBody User user) {
        user.setCreated(Instant.now());
        return userRepository.save(user);
    }

    @DeleteMapping("user/{id}")
    public Mono<Void> delete(@PathVariable long id) {
        return userRepository.deleteById(id);
    }

    @GetMapping("users")
    public Flux<User> getWithLimit(@RequestParam int limit) {
        return userRepository.findWithLimit(limit);
    }

}