/*
 * Copyright (c) 2018 Mockito contributors
 * This program is made available under the terms of the MIT License.
 */
package org.mockitoutil.async;

import static java.util.concurrent.TimeUnit.MILLISECONDS;

import static org.junit.Assert.assertEquals;
import static org.mockitoutil.Stopwatch.createNotStarted;

import java.util.concurrent.atomic.AtomicInteger;

import org.junit.After;
import org.junit.Test;
import org.mockitoutil.Stopwatch;

public class AsyncTestingTest {

    private AsyncTesting async = new AsyncTesting();
    private Stopwatch watch = createNotStarted();

    @After
    public void after() {
        async.cleanUp();
    }

    @Test
    public void sanity_test() {
        // given
        watch.start();
        final AtomicInteger value = new AtomicInteger(0);

        // when
        async.runAfter(
                200,
                new Runnable() {
                    public void run() {
                        value.incrementAndGet();
                    }
                });

        // then the runnable is truly async and has not ran yet:
        assertEquals(0, value.get());

        // after some wait...
        watch.waitFor(300);

        // we actually waited for some time
        watch.assertElapsedTimeIsMoreThan(200, MILLISECONDS);

        // and the async has actually ran:
        assertEquals(1, value.get());
    }
}