1/* 2 * Copyright (c) 2013, Oracle and/or its affiliates. All rights reserved. 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4 * 5 * This code is free software; you can redistribute it and/or modify it 6 * under the terms of the GNU General Public License version 2 only, as 7 * published by the Free Software Foundation. 8 * 9 * This code is distributed in the hope that it will be useful, but WITHOUT 10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License 12 * version 2 for more details (a copy is included in the LICENSE file that 13 * accompanied this code). 14 * 15 * You should have received a copy of the GNU General Public License version 16 * 2 along with this work; if not, write to the Free Software Foundation, 17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. 18 * 19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA 20 * or visit www.oracle.com if you need additional information or have any 21 * questions. 22 */ 23package java.util.stream; 24 25/** 26 * The base type of a stateless test operation 27 */ 28interface StatelessTestOp<E_IN, E_OUT> extends IntermediateTestOp<E_IN, E_OUT> { 29 30 @SuppressWarnings({"rawtypes", "unchecked"}) 31 public static<T> AbstractPipeline chain(AbstractPipeline upstream, 32 StatelessTestOp<?, T> op) { 33 int flags = op.opGetFlags(); 34 switch (op.outputShape()) { 35 case REFERENCE: 36 return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { 37 public Sink opWrapSink(int flags, Sink<T> sink) { 38 return op.opWrapSink(flags, isParallel(), sink); 39 } 40 }; 41 case INT_VALUE: 42 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 43 public Sink opWrapSink(int flags, Sink sink) { 44 return op.opWrapSink(flags, isParallel(), sink); 45 } 46 }; 47 case LONG_VALUE: 48 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 49 @Override 50 public Sink opWrapSink(int flags, Sink sink) { 51 return op.opWrapSink(flags, isParallel(), sink); 52 } 53 }; 54 case DOUBLE_VALUE: 55 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { 56 @Override 57 public Sink opWrapSink(int flags, Sink sink) { 58 return op.opWrapSink(flags, isParallel(), sink); 59 } 60 }; 61 default: throw new IllegalStateException(op.outputShape().toString()); 62 } 63 } 64 65 default StreamShape inputShape() { return StreamShape.REFERENCE; } 66 67 default StreamShape outputShape() { return StreamShape.REFERENCE; } 68 69 default int opGetFlags() { return 0; } 70 71 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink); 72} 73 74