Add support for the setTimeout(), clearTimeout(), setInterval() and

clearInterval() methods.

Author: javadev

lodash-plugin/pom.xml

@@ -230,7 +230,7 @@
     <dependency>
       <groupId>com.github.javadev</groupId>
       <artifactId>underscore</artifactId>
-      <version>1.11-SNAPSHOT</version>
+      <version>1.13-SNAPSHOT</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>

math-plugin/pom.xml

@@ -206,7 +206,7 @@
     <dependency>
       <groupId>com.github.javadev</groupId>
       <artifactId>underscore</artifactId>
-      <version>1.11-SNAPSHOT</version>
+      <version>1.13-SNAPSHOT</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>

pom.xml

@@ -5,7 +5,7 @@
   <groupId>com.github.javadev</groupId>
   <artifactId>underscore</artifactId>
   <packaging>jar</packaging>
-  <version>1.11-SNAPSHOT</version>
+  <version>1.13-SNAPSHOT</version>
   <name>java port of Underscore.js</name>
   <description>The java port of Underscore.js</description>
   <url>https://github.com/javadev/underscore-java</url>

src/main/java/com/github/underscore/$.java

@@ -2180,6 +2180,45 @@ public Optional<String> getString() {
         return string;
     }
 
+    public static <T> java.util.concurrent.ScheduledFuture setTimeout(final Function<T> function,
+        final int delayMilliseconds) {
+        final java.util.concurrent.ScheduledExecutorService scheduler =
+            java.util.concurrent.Executors.newSingleThreadScheduledExecutor();
+        final java.util.concurrent.ScheduledFuture future = scheduler.schedule(
+            new Runnable() {
+                public void run() {
+                    function.apply();
+                }
+            }, delayMilliseconds, java.util.concurrent.TimeUnit.MILLISECONDS);
+        scheduler.shutdown();
+        return future;
+    }
+
+    public static void clearTimeout(java.util.concurrent.ScheduledFuture scheduledFuture) {
+        if (scheduledFuture != null) {
+            scheduledFuture.cancel(true);
+        }
+    }
+
+    public static <T> java.util.concurrent.ScheduledFuture setInterval(final Function<T> function,
+        final int delayMilliseconds) {
+        final java.util.concurrent.ScheduledExecutorService scheduler =
+            java.util.concurrent.Executors.newSingleThreadScheduledExecutor();
+        final java.util.concurrent.ScheduledFuture future = scheduler.scheduleAtFixedRate(
+            new Runnable() {
+                public void run() {
+                    function.apply();
+                }
+            }, delayMilliseconds, delayMilliseconds, java.util.concurrent.TimeUnit.MILLISECONDS);
+        return future;
+    }
+
+    public static void clearInterval(java.util.concurrent.ScheduledFuture scheduledFuture) {
+        if (scheduledFuture != null) {
+            scheduledFuture.cancel(true);
+        }
+    }
+
     @SuppressWarnings("unchecked")
     protected static <T> List<T> newArrayList() {
         try {

src/test/java/com/github/underscore/FunctionsTest.java

@@ -287,4 +287,48 @@ public void iteratee() {
         final List<Object> result = $.map(stooges, $.iteratee("age"));
         assertEquals("[25, 21, 23]", result.toString());
     }
+
+    @Test
+    public void setTimeout() throws Exception {
+        final Integer[] counter = new Integer[] {0};
+        Function<Void> incr = new Function<Void>() { public Void apply() {
+            counter[0]++; return null; } };
+        $.setTimeout(incr, 0);
+        Thread.sleep(40);
+        assertEquals(1, counter[0].intValue());
+    }
+
+    @Test
+    public void clearTimeout() throws Exception {
+        final Integer[] counter = new Integer[] {0};
+        Function<Void> incr = new Function<Void>() { public Void apply() {
+            counter[0]++; return null; } };
+        java.util.concurrent.ScheduledFuture future = $.setTimeout(incr, 10);
+        $.clearTimeout(future);
+        $.clearTimeout(null);
+        Thread.sleep(40);
+        assertEquals(0, counter[0].intValue());
+    }
+
+    @Test
+    public void setInterval() throws Exception {
+        final Integer[] counter = new Integer[] {0};
+        Function<Void> incr = new Function<Void>() { public Void apply() {
+            counter[0]++; return null; } };
+        $.setInterval(incr, 10);
+        Thread.sleep(45);
+        assertEquals(4, counter[0].intValue());
+    }
+
+    @Test
+    public void clearInterval() throws Exception {
+        final Integer[] counter = new Integer[] {0};
+        Function<Void> incr = new Function<Void>() { public Void apply() {
+            counter[0]++; return null; } };
+        java.util.concurrent.ScheduledFuture future = $.setInterval(incr, 10);
+        $.clearInterval(future);
+        $.clearInterval(null);
+        Thread.sleep(40);
+        assertEquals(0, counter[0].intValue());
+    }
 }

string-plugin/pom.xml

@@ -230,7 +230,7 @@
     <dependency>
       <groupId>com.github.javadev</groupId>
       <artifactId>underscore</artifactId>
-      <version>1.11-SNAPSHOT</version>
+      <version>1.13-SNAPSHOT</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>