@@ -34,7 +34,7 @@ class CloseableIteratorUnitTests {
34
34
@ Test // DATACMNS-1637
35
35
void shouldCreateStream () {
36
36
37
- var iterator = new CloseableIteratorImpl <String >(Arrays .asList ("1" , "2" , "3" ).iterator ());
37
+ var iterator = new CloseableIteratorImpl <>(Arrays .asList ("1" , "2" , "3" ).iterator ());
38
38
39
39
var collection = iterator .stream ().map (it -> "hello " + it ).collect (Collectors .toList ());
40
40
@@ -45,27 +45,37 @@ void shouldCreateStream() {
45
45
@ Test // GH-2519
46
46
void shouldCount () {
47
47
48
- CloseableIteratorImpl < String > iterator = new CloseableIteratorImpl <>(Arrays .asList ("1" , "2" , "3" ).iterator ());
48
+ var iterator = new CloseableIteratorImpl <>(Arrays .asList ("1" , "2" , "3" ).iterator ());
49
49
50
- long count = iterator .stream ().count ();
50
+ var count = iterator .stream ().count ();
51
51
52
52
assertThat (count ).isEqualTo (3 );
53
53
}
54
54
55
55
@ Test // GH-2519
56
56
void shouldCountLargeStream () {
57
57
58
- CloseableIteratorImpl < Integer > iterator = new CloseableIteratorImpl <>(IntStream .range (0 , 2048 ).boxed ().iterator ());
58
+ var iterator = new CloseableIteratorImpl <>(IntStream .range (0 , 2048 ).boxed ().iterator ());
59
59
60
- long count = iterator .stream ().count ();
60
+ var count = iterator .stream ().count ();
61
61
62
62
assertThat (count ).isEqualTo (2048 );
63
63
}
64
64
65
+ @ Test // GH-2519
66
+ void shouldApplyToList () {
67
+
68
+ var iterator = new CloseableIteratorImpl <>(Arrays .asList ("1" , "2" , "3" ).iterator ());
69
+
70
+ var list = iterator .stream ().toList ();
71
+
72
+ assertThat (list ).isEqualTo (Arrays .asList ("1" , "2" , "3" ));
73
+ }
74
+
65
75
@ Test // DATACMNS-1637
66
76
void closeStreamShouldCloseIterator () {
67
77
68
- var iterator = new CloseableIteratorImpl <String >(Arrays .asList ("1" , "2" , "3" ).iterator ());
78
+ var iterator = new CloseableIteratorImpl <>(Arrays .asList ("1" , "2" , "3" ).iterator ());
69
79
70
80
try (var stream = iterator .stream ()) {
71
81
assertThat (stream .findFirst ()).hasValue ("1" );
0 commit comments