| /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| LongNodeTest.java | 90 private Node.OfLong fill(long[] array, Node.Builder.OfLong nb) {
98 private Node.OfLong degenerateTree(PrimitiveIterator.OfLong it) {
105 return new Nodes.ConcNode.OfLong(Nodes.node(new long[] {i}), degenerateTree(it));
112 private Node.OfLong tree(List<Long> l, Function<List<Long>, Node.OfLong> m) {
117 return new Nodes.ConcNode.OfLong(
124 public void testAsArray(long[] array, Node.OfLong n) {
129 public void testFlattenAsArray(long[] array, Node.OfLong n)
[all...] |
| SpinedBufferTest.java | 228 SpinedBuffer.OfLong sb = new SpinedBuffer.OfLong();
238 public void testLongSpliterator(long[] array, SpinedBuffer.OfLong sb) {
246 public void testLongLastSplit(long[] array, SpinedBuffer.OfLong sb) {
247 Spliterator.OfLong spliterator = sb.spliterator();
248 Spliterator.OfLong split = spliterator.trySplit();
271 SpinedBuffer.OfLong sb = new SpinedBuffer.OfLong();
276 PrimitiveIterator.OfLong it = sb.iterator();
|
| SliceSpliteratorTest.java | 103 Spliterator.OfLong s = Arrays.spliterator(source.stream().mapToLong(i->i).toArray());
105 return new StreamSpliterators.SliceSpliterator.OfLong(s, skip, limit);
108 data.add(new Object[]{"StreamSpliterators.SliceSpliterator.OfLong", r});
121 data.add(new Object[]{"StreamSpliterators.SliceSpliterator.OfLong", r});
161 Spliterator.OfLong s = Arrays.spliterator(source.stream().mapToLong(i->i).toArray());
163 return new StreamSpliterators.UnorderedSliceSpliterator.OfLong(s, skip, limit);
166 data.add(new Object[]{"StreamSpliterators.UnorderedSliceSpliterator.OfLong", r});
180 data.add(new Object[]{"StreamSpliterators.UnorderedSliceSpliterator.OfLong", r});
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| Nodes.java | 69 private static final Node.OfLong EMPTY_LONG_NODE = new EmptyNode.OfLong();
120 return (Node<T>) new ConcNode.OfLong((Node.OfLong) left, (Node.OfLong) right);
222 * Produces a {@link Node.OfLong} describing a long[] array.
229 static Node.OfLong node(final long[] array) {
234 * Produces a {@link Node.Builder.OfLong}.
239 * @return a {@code Node.Builder.OfLong}
241 static Node.Builder.OfLong longBuilder(long exactSizeIfKnown)
[all...] |
| StreamSpliterators.java | 380 extends AbstractWrappingSpliterator<P_IN, Long, SpinedBuffer.OfLong>
381 implements Spliterator.OfLong {
402 SpinedBuffer.OfLong b = new SpinedBuffer.OfLong();
404 bufferSink = ph.wrapSink((Sink.OfLong) b::accept);
409 public Spliterator.OfLong trySplit() {
410 return (Spliterator.OfLong) super.trySplit();
428 ph.wrapAndCopyInto((Sink.OfLong) consumer::accept, spliterator);
586 static final class OfLong
587 extends OfPrimitive<Long, LongConsumer, Spliterator.OfLong>
[all...] |
| LongStream.java | 672 PrimitiveIterator.OfLong iterator();
675 Spliterator.OfLong spliterator();
735 final PrimitiveIterator.OfLong iterator = new PrimitiveIterator.OfLong() {
766 new StreamSpliterators.InfiniteSupplyingSpliterator.OfLong(Long.MAX_VALUE, s), false);
[all...] |
| Node.java | 210 interface OfLong extends Node.Builder<Long>, Sink.OfLong {
212 Node.OfLong build();
387 interface OfLong extends OfPrimitive<Long, LongConsumer, long[], Spliterator.OfLong, OfLong> {
404 Tripwire.trip(getClass(), "{0} calling Node.OfLong.forEachRemaining(Consumer)");
429 default Node.OfLong truncate(long from, long to, IntFunction<Long[]> generator) {
433 Spliterator.OfLong spliterator = spliterator();
434 Node.Builder.OfLong nodeBuilder = Nodes.longBuilder(size)
[all...] |
| StreamSupport.java | 185 * {@code Spliterator.OfLong}.
198 * @param spliterator a {@code Spliterator.OfLong} describing the stream elements
204 public static LongStream longStream(Spliterator.OfLong spliterator,
213 * {@code Supplier} of {@code Spliterator.OfLong}.
222 * more efficient to use {@link #longStream(java.util.Spliterator.OfLong, boolean)}
232 * @param supplier a {@code Supplier} of a {@code Spliterator.OfLong}
234 * {@code Spliterator.OfLong}. The characteristics must be equal to
241 * @see #longStream(java.util.Spliterator.OfLong, boolean)
243 public static LongStream longStream(Supplier<? extends Spliterator.OfLong> supplier,
|
| LongPipeline.java | 111 * Adapt a {@code Spliterator<Long>} to a {@code Spliterator.OfLong}.
114 * The implementation attempts to cast to a Spliterator.OfLong, and throws
117 private static Spliterator.OfLong adapt(Spliterator<Long> s) {
118 if (s instanceof Spliterator.OfLong) {
119 return (Spliterator.OfLong) s;
153 public final Spliterator.OfLong lazySpliterator(Supplier<? extends Spliterator<Long>> supplier) {
154 return new StreamSpliterators.DelegatingSpliterator.OfLong((Supplier<Spliterator.OfLong>) supplier);
159 Spliterator.OfLong spl = adapt(spliterator);
173 public final PrimitiveIterator.OfLong iterator()
[all...] |
| Streams.java | 185 static final class RangeLongSpliterator implements Spliterator.OfLong {
261 public Spliterator.OfLong trySplit() {
517 extends AbstractStreamBuilderImpl<Long, Spliterator.OfLong>
518 implements LongStream.Builder, Spliterator.OfLong {
525 SpinedBuffer.OfLong buffer;
552 buffer = new SpinedBuffer.OfLong();
823 static class OfLong
824 extends ConcatSpliterator.OfPrimitive<Long, LongConsumer, Spliterator.OfLong>
825 implements Spliterator.OfLong {
826 OfLong(Spliterator.OfLong aSpliterator, Spliterator.OfLong bSpliterator)
[all...] |
| Sink.java | 207 interface OfLong extends Sink<Long>, LongConsumer {
214 Tripwire.trip(getClass(), "{0} calling Sink.OfLong.accept(Long)");
305 * {@code Sink} of unknown input shape and produces a {@code Sink.OfLong}.
309 static abstract class ChainedLong<E_OUT> implements Sink.OfLong {
|
| SliceOps.java | 90 .SliceSpliterator.OfLong((Spliterator.OfLong) s, skip, sliceFence);
346 Spliterator.OfLong unorderedSkipLimitSpliterator(
347 Spliterator.OfLong s, long skip, long limit, long sizeIfKnown) {
354 return new StreamSpliterators.UnorderedSliceSpliterator.OfLong(s, skip, limit);
362 return new StreamSpliterators.SliceSpliterator.OfLong(
363 (Spliterator.OfLong) helper.wrapSpliterator(spliterator),
368 (Spliterator.OfLong) helper.wrapSpliterator(spliterator),
391 Spliterator.OfLong s = unorderedSkipLimitSpliterator(
392 (Spliterator.OfLong) helper.wrapSpliterator(spliterator)
[all...] |
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| LongStreamTestDataProvider.java | 89 SpinedBuffer.OfLong isl = new SpinedBuffer.OfLong();
110 SpinedBuffer.OfLong isl = new SpinedBuffer.OfLong();
143 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfLong> s) {
|
| TestData.java | 72 public interface OfLong extends TestData<Long, LongStream> { }
144 public static <T> OfLong ofArray(String name, long[] array) {
149 public static OfLong ofSpinedBuffer(String name, SpinedBuffer.OfLong buffer) {
153 SpinedBuffer.OfLong::spliterator,
157 public static OfLong ofLongSupplier(String name, Supplier<LongStream> supplier) {
165 public static OfLong ofNode(String name, Node.OfLong node) {
170 Node.OfLong::spliterator,
306 extends AbstractTestData<Long, LongStream, I, Spliterator.OfLong>
[all...] |
| CollectorOps.java | 101 public static class OfLong extends TestParallelSizedOp<Long> {
102 public OfLong() {
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| LongStreamTestDataProvider.java | 93 SpinedBuffer.OfLong isl = new SpinedBuffer.OfLong();
114 SpinedBuffer.OfLong isl = new SpinedBuffer.OfLong();
147 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfLong> s) {
|
| TestData.java | 73 public interface OfLong extends TestData<Long, LongStream> { }
145 public static <T> OfLong ofArray(String name, long[] array) {
150 public static OfLong ofSpinedBuffer(String name, SpinedBuffer.OfLong buffer) {
154 SpinedBuffer.OfLong::spliterator,
158 public static OfLong ofLongSupplier(String name, Supplier<LongStream> supplier) {
166 public static OfLong ofNode(String name, Node.OfLong node) {
171 Node.OfLong::spliterator,
307 extends AbstractTestData<Long, LongStream, I, Spliterator.OfLong>
[all...] |
| CollectorOps.java | 102 public static class OfLong extends TestParallelSizedOp<Long> {
103 public OfLong() {
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| RangeTest.java | 206 TestData.OfLong longRangeData(long start, long end) {
210 TestData.OfLong longRangeClosedData(long start, long end) {
244 Spliterator.OfLong s = LongStream.range(Long.MIN_VALUE, Long.MAX_VALUE).spliterator();
249 Spliterator.OfLong s1 = s.trySplit();
253 Spliterator.OfLong s2 = s1.trySplit();
270 Spliterator.OfLong s = LongStream.range(start, end).spliterator();
275 Spliterator.OfLong s1 = s.trySplit();
294 Spliterator.OfLong s = LongStream.rangeClosed(Long.MIN_VALUE, Long.MAX_VALUE).spliterator();
299 Spliterator.OfLong s1 = s.trySplit();
303 Spliterator.OfLong s2 = s1.trySplit()
[all...] |
| PrimitiveAverageOpTest.java | 44 public void testOps(String name, TestData.OfLong data) {
|
| SpliteratorTest.java | 58 public void testLongSpliterator(String name, Supplier<Spliterator.OfLong> supplier) {
|
| StreamSpliteratorTest.java | 159 private static class OfLong extends ProxyNoExactSizeSpliterator<Long> implements Spliterator.OfLong {
160 final Spliterator.OfLong psp;
162 private OfLong(Spliterator.OfLong sp, boolean proxyEstimateSize) {
168 public Spliterator.OfLong trySplit() {
170 Spliterator.OfLong prefix = psp.trySplit();
178 return Spliterator.OfLong.super.tryAdvance(consumer);
183 Spliterator.OfLong.super.forEachRemaining(consumer);
457 Spliterator.OfLong sp = intermediateOp.apply(LongStream.range(0, 1000)).spliterator()
[all...] |
| /libcore/ojluni/src/main/java/java/util/ |
| Spliterators.java | 35 * {@link Spliterator.OfInt}, {@link Spliterator.OfLong}, and
83 * Creates an empty {@code Spliterator.OfLong}
91 public static Spliterator.OfLong emptyLongSpliterator() {
95 private static final Spliterator.OfLong EMPTY_LONG_SPLITERATOR =
96 new EmptySpliterator.OfLong();
244 * Creates a {@code Spliterator.OfLong} covering the elements of a given array,
266 public static Spliterator.OfLong spliterator(long[] array,
272 * Creates a {@code Spliterator.OfLong} covering a range of elements of a
303 public static Spliterator.OfLong spliterator(long[] array, int fromIndex, int toIndex,
539 * Creates a {@code Spliterator.OfLong} using a give
[all...] |
| Spliterator.java | 108 * {@link OfInt int}, {@link OfLong long}, and {@link OfDouble double} values.
595 * @see Spliterator.OfLong
[all...] |
| /libcore/luni/src/test/java/libcore/java/util/ |
| SpliteratorsTest.java | 67 Spliterator.OfLong empty = Spliterators.emptyLongSpliterator();
263 Spliterator.OfLong sp = Spliterators.spliterator(elements, 2, 6, 0);
290 Spliterator.OfLong longSp = Spliterators.spliterator(elements, 0);
303 Spliterator.OfLong split1 = longSp.trySplit();
309 Spliterator.OfLong split2 = split1.trySplit();
389 Spliterator.OfLong longSp = Spliterators.spliterator(longElements, 0);
539 private static class CannedLongPrimitiveIterator implements PrimitiveIterator.OfLong {
654 PrimitiveIterator.OfLong elements = new CannedLongPrimitiveIterator(data);
655 Spliterator.OfLong longSp = Spliterators.spliterator(elements, 16 /* size */, 0);
668 Spliterator.OfLong split1 = longSp.trySplit()
[all...] |
