@@ -0,0 +1,504 @@
+package com.flightstats.util;%0A%0Aimport org.junit.Test;%0A%0Aimport java.util.concurrent.atomic.AtomicInteger;%0A%0Aimport static org.junit.Assert.assertEquals;%0Aimport static org.junit.Assert.assertNull;%0A%0Apublic class StreamsTest %7B%0A%0A    @Test%0A    public void testTimes() throws Exception %7B%0A        AtomicInteger resultCt = new AtomicInteger(0);%0A    %09Streams.times(100).forEach(x -%3E %7B%0A            assertNull(x);%0A            resultCt.incrementAndGet();%0A        %7D);%0A        assertEquals(100, resultCt.get());%0A    %7D%0A%0A%7D

add basic test