--- old/test/java/util/stream/bootlib/java/util/stream/StatelessTestOp.java 2015-11-13 15:38:24.874966940 -0800 +++ /dev/null 2015-05-15 15:37:46.536788447 -0700 @@ -1,73 +0,0 @@ -/* - * Copyright (c) 2013, Oracle and/or its affiliates. All rights reserved. - * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. - * - * This code is free software; you can redistribute it and/or modify it - * under the terms of the GNU General Public License version 2 only, as - * published by the Free Software Foundation. - * - * This code is distributed in the hope that it will be useful, but WITHOUT - * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or - * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License - * version 2 for more details (a copy is included in the LICENSE file that - * accompanied this code). - * - * You should have received a copy of the GNU General Public License version - * 2 along with this work; if not, write to the Free Software Foundation, - * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. - * - * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA - * or visit www.oracle.com if you need additional information or have any - * questions. - */ -package java.util.stream; - -/** - * The base type of a stateless test operation - */ -interface StatelessTestOp extends IntermediateTestOp { - - @SuppressWarnings({"rawtypes", "unchecked"}) - public static AbstractPipeline chain(AbstractPipeline upstream, - StatelessTestOp op) { - int flags = op.opGetFlags(); - switch (op.outputShape()) { - case REFERENCE: - return new ReferencePipeline.StatelessOp(upstream, op.inputShape(), flags) { - public Sink opWrapSink(int flags, Sink sink) { - return op.opWrapSink(flags, isParallel(), sink); - } - }; - case INT_VALUE: - return new IntPipeline.StatelessOp(upstream, op.inputShape(), flags) { - public Sink opWrapSink(int flags, Sink sink) { - return op.opWrapSink(flags, isParallel(), sink); - } - }; - case LONG_VALUE: - return new LongPipeline.StatelessOp(upstream, op.inputShape(), flags) { - @Override - Sink opWrapSink(int flags, Sink sink) { - return op.opWrapSink(flags, isParallel(), sink); - } - }; - case DOUBLE_VALUE: - return new DoublePipeline.StatelessOp(upstream, op.inputShape(), flags) { - @Override - Sink opWrapSink(int flags, Sink sink) { - return op.opWrapSink(flags, isParallel(), sink); - } - }; - default: throw new IllegalStateException(op.outputShape().toString()); - } - } - - default StreamShape inputShape() { return StreamShape.REFERENCE; } - - default StreamShape outputShape() { return StreamShape.REFERENCE; } - - default int opGetFlags() { return 0; } - - Sink opWrapSink(int flags, boolean parallel, Sink sink); -} - --- /dev/null 2015-05-15 15:37:46.536788447 -0700 +++ new/test/java/util/stream/bootlib/java.base/java/util/stream/StatelessTestOp.java 2015-11-13 15:38:24.666958094 -0800 @@ -0,0 +1,73 @@ +/* + * Copyright (c) 2013, Oracle and/or its affiliates. All rights reserved. + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * This code is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License version 2 only, as + * published by the Free Software Foundation. + * + * This code is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License + * version 2 for more details (a copy is included in the LICENSE file that + * accompanied this code). + * + * You should have received a copy of the GNU General Public License version + * 2 along with this work; if not, write to the Free Software Foundation, + * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. + * + * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA + * or visit www.oracle.com if you need additional information or have any + * questions. + */ +package java.util.stream; + +/** + * The base type of a stateless test operation + */ +interface StatelessTestOp extends IntermediateTestOp { + + @SuppressWarnings({"rawtypes", "unchecked"}) + public static AbstractPipeline chain(AbstractPipeline upstream, + StatelessTestOp op) { + int flags = op.opGetFlags(); + switch (op.outputShape()) { + case REFERENCE: + return new ReferencePipeline.StatelessOp(upstream, op.inputShape(), flags) { + public Sink opWrapSink(int flags, Sink sink) { + return op.opWrapSink(flags, isParallel(), sink); + } + }; + case INT_VALUE: + return new IntPipeline.StatelessOp(upstream, op.inputShape(), flags) { + public Sink opWrapSink(int flags, Sink sink) { + return op.opWrapSink(flags, isParallel(), sink); + } + }; + case LONG_VALUE: + return new LongPipeline.StatelessOp(upstream, op.inputShape(), flags) { + @Override + Sink opWrapSink(int flags, Sink sink) { + return op.opWrapSink(flags, isParallel(), sink); + } + }; + case DOUBLE_VALUE: + return new DoublePipeline.StatelessOp(upstream, op.inputShape(), flags) { + @Override + Sink opWrapSink(int flags, Sink sink) { + return op.opWrapSink(flags, isParallel(), sink); + } + }; + default: throw new IllegalStateException(op.outputShape().toString()); + } + } + + default StreamShape inputShape() { return StreamShape.REFERENCE; } + + default StreamShape outputShape() { return StreamShape.REFERENCE; } + + default int opGetFlags() { return 0; } + + Sink opWrapSink(int flags, boolean parallel, Sink sink); +} +