@Test
public void testEnsure() throws InterruptedException {

    testOnce(new Once() {
        @Override
        protected void run() throws InterruptedException {
            Thread.sleep(1000);
            results.put(this, this);
        }
    });
}