// Path: src/test/java/org/dataloader/fixtures/TestingClock.java
// public class TestingClock extends Clock {
// 
//     private Clock clock;
// 
//     public TestingClock() {
//         clock = Clock.fixed(Instant.ofEpochMilli(0), ZoneId.systemDefault());
//     }
// 
//     public Clock jump(int millisDelta) {
//         clock = Clock.offset(clock, Duration.ofMillis(millisDelta));
//         return clock;
//     }
// 
//     @Override
//     public ZoneId getZone() {
//         return clock.getZone();
//     }
// 
//     @Override
//     public Clock withZone(ZoneId zone) {
//         return clock.withZone(zone);
//     }
// 
//     @Override
//     public Instant instant() {
//         return clock.instant();
//     }
// }
// 
// Path: src/test/java/org/dataloader/fixtures/TestKit.java
// public static <T> BatchLoader<T, T> keysAsValues() {
//     return CompletableFuture::completedFuture;
// }


import org.dataloader.fixtures.TestingClock;
import org.junit.Test;
import java.time.Instant;
import static org.dataloader.fixtures.TestKit.keysAsValues;
import static org.hamcrest.Matchers.equalTo;
import static org.junit.Assert.assertThat;
package org.dataloader;




@SuppressWarnings("UnusedReturnValue")
public class DataLoaderTimeTest {


    @Test
    public void should_set_and_instant_if_dispatched() {

        TestingClock clock = new TestingClock();
// Path: src/test/java/org/dataloader/fixtures/TestingClock.java
// public class TestingClock extends Clock {
// 
//     private Clock clock;
// 
//     public TestingClock() {
//         clock = Clock.fixed(Instant.ofEpochMilli(0), ZoneId.systemDefault());
//     }
// 
//     public Clock jump(int millisDelta) {
//         clock = Clock.offset(clock, Duration.ofMillis(millisDelta));
//         return clock;
//     }
// 
//     @Override
//     public ZoneId getZone() {
//         return clock.getZone();
//     }
// 
//     @Override
//     public Clock withZone(ZoneId zone) {
//         return clock.withZone(zone);
//     }
// 
//     @Override
//     public Instant instant() {
//         return clock.instant();
//     }
// }
// 
// Path: src/test/java/org/dataloader/fixtures/TestKit.java
// public static <T> BatchLoader<T, T> keysAsValues() {
//     return CompletableFuture::completedFuture;
// }


// Path: src/test/java/org/dataloader/DataLoaderTimeTest.java
import org.dataloader.fixtures.TestingClock;
import org.junit.Test;
import java.time.Instant;
import static org.dataloader.fixtures.TestKit.keysAsValues;
import static org.hamcrest.Matchers.equalTo;
import static org.junit.Assert.assertThat;

package org.dataloader;




@SuppressWarnings("UnusedReturnValue")
public class DataLoaderTimeTest {


    @Test
    public void should_set_and_instant_if_dispatched() {

        TestingClock clock = new TestingClock();
        DataLoader<Integer, Integer> dataLoader = new ClockDataLoader<>(keysAsValues(), clock);