@SuppressWarnings("unchecked") @Test void testAddStream() { User user = mock(User.class); when(delegateRepository.add(any(Stream.class))) .thenAnswer( invocation -> Long.valueOf(((Stream<User>) invocation.getArgument(0)).count()).intValue()); userRepositoryValidationDecorator.add(Stream.of(user)); verify(userValidator).validate(user); }
@Override public void add(User user) { validateAddUser(user); super.add(user); }
UserRepositoryValidationDecorator extends AbstractRepositoryDecorator<User> { @Override public void add(User user) { validateAddUser(user); super.add(user); } }
UserRepositoryValidationDecorator extends AbstractRepositoryDecorator<User> { @Override public void add(User user) { validateAddUser(user); super.add(user); } UserRepositoryValidationDecorator(
      Repository<User> delegateRepository, UserValidator userValidator); }
UserRepositoryValidationDecorator extends AbstractRepositoryDecorator<User> { @Override public void add(User user) { validateAddUser(user); super.add(user); } UserRepositoryValidationDecorator(
      Repository<User> delegateRepository, UserValidator userValidator); @Override void add(User user); @Override Integer add(Stream<User> userStream); @Override void update(User user); @Override void update(Stream<User> userStream); }
UserRepositoryValidationDecorator extends AbstractRepositoryDecorator<User> { @Override public void add(User user) { validateAddUser(user); super.add(user); } UserRepositoryValidationDecorator(
      Repository<User> delegateRepository, UserValidator userValidator); @Override void add(User user); @Override Integer add(Stream<User> userStream); @Override void update(User user); @Override void update(Stream<User> userStream);  }