@Override
    public void remove(final Integer otp) {
        lock.tryLock(__ -> {
            val dataset = storage.asMap();
            dataset.values().forEach(tokens -> tokens.removeIf(t -> otp.equals(t.getToken())));
        });
    }
This is {@link CachingOneTimeTokenRepository}.

@author Misagh Moayyed
@since 5.1.0
support/cas-server-support-otp-mfa-core/src/main/java/org/apereo/cas/otp/repository/token/CachingOneTimeTokenRepository.java