Lines Matching refs:limit
71 assertCountSum(IntStream.range(0, 0).limit(4).boxed(), 0, 0); in testLimit()
72 assertCountSum(IntStream.range(1, 3).limit(4).boxed(), 2, 3); in testLimit()
73 assertCountSum(IntStream.range(1, 5).limit(4).boxed(), 4, 10); in testLimit()
74 assertCountSum(IntStream.range(1, 9).limit(4).boxed(), 4, 10); in testLimit()
76 assertCountSum(IntStream.range(0, 0).parallel().limit(4).boxed(), 0, 0); in testLimit()
77 assertCountSum(IntStream.range(1, 3).parallel().limit(4).boxed(), 2, 3); in testLimit()
78 assertCountSum(IntStream.range(1, 5).parallel().limit(4).boxed(), 4, 10); in testLimit()
79 assertCountSum(IntStream.range(1, 9).parallel().limit(4).boxed(), 4, 10); in testLimit()
81 exerciseOps(EMPTY_INT_ARRAY, s -> s.limit(0), EMPTY_INT_ARRAY); in testLimit()
82 exerciseOps(EMPTY_INT_ARRAY, s -> s.limit(10), EMPTY_INT_ARRAY); in testLimit()
84 exerciseOps(IntStream.range(1, 2).toArray(), s -> s.limit(0), EMPTY_INT_ARRAY); in testLimit()
85 … exerciseOps(IntStream.range(1, 2).toArray(), s -> s.limit(1), IntStream.range(1, 2).toArray()); in testLimit()
86 exerciseOps(IntStream.range(1, 101).toArray(), s -> s.limit(0), EMPTY_INT_ARRAY); in testLimit()
87 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.limit(10), IntStream.range(1, 11).toArray()); in testLimit()
88 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.limit(10).limit(10), IntStream.range(1, 11).… in testLimit()
89 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.limit(100), IntStream.range(1, 101).toArray(… in testLimit()
90 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.limit(100).limit(10), IntStream.range(1, 11)… in testLimit()
91 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.limit(200), IntStream.range(1, 101).toArray(… in testLimit()
95 exerciseOps(EMPTY_INT_ARRAY, s -> s.skip(0).limit(0), EMPTY_INT_ARRAY); in testSkipLimit()
96 exerciseOps(EMPTY_INT_ARRAY, s -> s.skip(0).limit(10), EMPTY_INT_ARRAY); in testSkipLimit()
97 exerciseOps(EMPTY_INT_ARRAY, s -> s.skip(10).limit(0), EMPTY_INT_ARRAY); in testSkipLimit()
98 exerciseOps(EMPTY_INT_ARRAY, s -> s.skip(10).limit(10), EMPTY_INT_ARRAY); in testSkipLimit()
100 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(0).limit(100), IntStream.range(1, 101).… in testSkipLimit()
101 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(0).limit(10), IntStream.range(1, 11).to… in testSkipLimit()
102 exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(0).limit(0), EMPTY_INT_ARRAY); in testSkipLimit()
103 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(10).limit(100), IntStream.range(11, 101… in testSkipLimit()
104 …exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(10).limit(10), IntStream.range(11, 21).… in testSkipLimit()
105 exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(10).limit(0), EMPTY_INT_ARRAY); in testSkipLimit()
106 … exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(100).limit(100), EMPTY_INT_ARRAY); in testSkipLimit()
107 exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(100).limit(10), EMPTY_INT_ARRAY); in testSkipLimit()
108 exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(100).limit(0), EMPTY_INT_ARRAY); in testSkipLimit()
109 … exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(200).limit(100), EMPTY_INT_ARRAY); in testSkipLimit()
110 exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(200).limit(10), EMPTY_INT_ARRAY); in testSkipLimit()
111 exerciseOps(IntStream.range(1, 101).toArray(), s -> s.skip(200).limit(0), EMPTY_INT_ARRAY); in testSkipLimit()
114 private int sliceSize(int dataSize, int skip, int limit) { in sliceSize() argument
116 if (limit >= 0) in sliceSize()
117 size = Math.min(size, limit); in sliceSize()
146 for (int limit : limits) { in testSkipLimitOps()
147 setContext("limit", limit); in testSkipLimitOps()
148 Collection<Integer> sr = exerciseOps(data, st -> st.skip(s).limit(limit)); in testSkipLimitOps()
149 assertEquals(sr.size(), sliceSize(sliceSize(data.size(), s), 0, limit)); in testSkipLimitOps() local
151 sr = exerciseOps(data, st -> st.skip(s).limit(limit)); in testSkipLimitOps()
152 assertEquals(sr.size(), sliceSize(data.size(), s, limit)); in testSkipLimitOps() local
161 for (int limit : limits) { in testLimitOps()
162 setContext("limit", limit); in testLimitOps()
163 Collection<Integer> sr = exerciseOps(data, st -> st.limit(limit)); in testLimitOps()
164 assertEquals(sr.size(), sliceSize(data.size(), 0, limit)); in testLimitOps() local
166 sr = exerciseOps(data, st -> st.limit(limit).limit(limit / 2)); in testLimitOps()
167 assertEquals(sr.size(), sliceSize(sliceSize(data.size(), 0, limit), 0, limit / 2)); in testLimitOps() local
172 exerciseOps(IntStream.range(1, 101).map(i -> 101 - i).toArray(), s -> s.limit(10).sorted()); in testLimitSort()
182 .limit(l).toArray(); in testLimitShortCircuit()
189 int[] l = IntStream.range(1, 1001).parallel().skip(200).limit(200).sequential().toArray(); in testSkipParallel()
195 int[] l = IntStream.range(1, 1001).parallel().limit(500).sequential().toArray(); in testLimitParallel()