Method testSleep

java/tests/src/main/java/tests/base/TestSleep.java:12–35

()

public class TestSleep extends BaseTest
{
        public java.util.concurrent.CompletableFuture<Object> testSleep()
        {
        
            return java.util.concurrent.CompletableFuture.supplyAsync(() -> {
        
            var exchange = new Exchange(new java.util.HashMap<String, Object>() {{
                put( "id", "sampleexchange" );
            }});
            Object start = exchange.milliseconds();
            Object sleepAmount = 100; // milliseconds
            (exchange.sleep(sleepAmount)).join();
            Object end = exchange.milliseconds();
            Object elapsed = Helpers.subtract(end, start);
            // Allow a small margin of error due to execution time
            Object marginOfError = 20;
            Object maxElapsed = Helpers.add(sleepAmount, marginOfError);
            Object elapsedBiggerThanSleep = Helpers.isGreaterThanOrEqual(elapsed, sleepAmount);
            Object elapsedLessThanMax = Helpers.isLessThanOrEqual(elapsed, maxElapsed);
            Assert(elapsedBiggerThanSleep, Helpers.add(Helpers.add(Helpers.add(Helpers.add("Elapsed time ", String.valueOf(elapsed)), "ms is less than sleep amount "), String.valueOf(sleepAmount)), "ms"));
            Assert(elapsedLessThanMax, Helpers.add(Helpers.add(Helpers.add(Helpers.add("Elapsed time ", String.valueOf(elapsed)), "ms exceeds sleep amount "), String.valueOf(maxElapsed)), "ms"));
            return true;
            }, io.github.ccxt.Exchange.VIRTUAL_EXECUTOR);
        
        }
}