30
31 import java.util.Random;
32 import java.util.Set;
33 import java.util.concurrent.CompletableFuture;
34 import java.util.concurrent.ExecutionException;
35 import java.util.concurrent.ThreadLocalRandom;
36 import java.util.concurrent.TimeUnit;
37 import java.util.concurrent.TimeoutException;
38 import java.util.function.Supplier;
39 import java.util.stream.Stream;
40
41 import static java.util.stream.Collectors.toList;
42 import static java.util.stream.Collectors.toSet;
43 import static org.testng.Assert.*;
44
45 /**
46 * @test
47 * @run testng RandomStreamTest
48 * @summary test stream methods on Random
49 * @author Brian Goetz
50 */
51 public class RandomStreamTest {
52
53 private static final int SIZE = 1000;
54
55 @DataProvider(name = "suppliers")
56 public Object[][] randomSuppliers() {
57 return new Object[][] {
58 {new Random(), SIZE},
59 {new SecureRandom(), SIZE}
60 };
61 }
62
63 @Test(dataProvider = "suppliers")
64 public void testRandomIntStream(final Random random, final int count) {
65 final List<Integer> destination = new ArrayList<>(count);
66 random.ints().limit(count).forEach(destination::add);
67 assertEquals(destination.size(), count);
68 }
69
|
30
31 import java.util.Random;
32 import java.util.Set;
33 import java.util.concurrent.CompletableFuture;
34 import java.util.concurrent.ExecutionException;
35 import java.util.concurrent.ThreadLocalRandom;
36 import java.util.concurrent.TimeUnit;
37 import java.util.concurrent.TimeoutException;
38 import java.util.function.Supplier;
39 import java.util.stream.Stream;
40
41 import static java.util.stream.Collectors.toList;
42 import static java.util.stream.Collectors.toSet;
43 import static org.testng.Assert.*;
44
45 /**
46 * @test
47 * @run testng RandomStreamTest
48 * @summary test stream methods on Random
49 * @author Brian Goetz
50 * @key randomness
51 */
52 public class RandomStreamTest {
53
54 private static final int SIZE = 1000;
55
56 @DataProvider(name = "suppliers")
57 public Object[][] randomSuppliers() {
58 return new Object[][] {
59 {new Random(), SIZE},
60 {new SecureRandom(), SIZE}
61 };
62 }
63
64 @Test(dataProvider = "suppliers")
65 public void testRandomIntStream(final Random random, final int count) {
66 final List<Integer> destination = new ArrayList<>(count);
67 random.ints().limit(count).forEach(destination::add);
68 assertEquals(destination.size(), count);
69 }
70
|