|
20 | 20 |
|
21 | 21 | import static org.assertj.core.api.Assertions.assertThat;
|
22 | 22 |
|
23 |
| -import java.io.IOException; |
24 | 23 | import java.util.Collections;
|
25 | 24 | import java.util.Iterator;
|
26 | 25 | import java.util.List;
|
|
43 | 42 |
|
44 | 43 | public class TestParallelIterable {
|
45 | 44 | @Test
|
46 |
| - public void closeParallelIteratorWithoutCompleteIteration() |
47 |
| - throws IOException, IllegalAccessException, NoSuchFieldException { |
| 45 | + public void closeParallelIteratorWithoutCompleteIteration() { |
48 | 46 | ExecutorService executor = Executors.newFixedThreadPool(1);
|
49 | 47 |
|
50 | 48 | Iterable<CloseableIterable<Integer>> transform =
|
@@ -76,8 +74,7 @@ public CloseableIterator<Integer> iterator() {
|
76 | 74 | }
|
77 | 75 |
|
78 | 76 | @Test
|
79 |
| - public void closeMoreDataParallelIteratorWithoutCompleteIteration() |
80 |
| - throws IOException, IllegalAccessException, NoSuchFieldException { |
| 77 | + public void closeMoreDataParallelIteratorWithoutCompleteIteration() { |
81 | 78 | ExecutorService executor = Executors.newFixedThreadPool(1);
|
82 | 79 | Iterator<Integer> integerIterator =
|
83 | 80 | new Iterator<Integer>() {
|
@@ -137,8 +134,7 @@ public CloseableIterator<Integer> iterator() {
|
137 | 134 | }
|
138 | 135 |
|
139 | 136 | @Test
|
140 |
| - public void limitQueueSize() throws IOException, IllegalAccessException, NoSuchFieldException { |
141 |
| - |
| 137 | + public void limitQueueSize() { |
142 | 138 | List<Iterable<Integer>> iterables =
|
143 | 139 | ImmutableList.of(
|
144 | 140 | () -> IntStream.range(0, 100).iterator(),
|
|
0 commit comments