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  */

    23 package java.util.stream;

    24 

    25 /**

    26  * The base type of a stateless test operation

    27  */

    28 interface 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                     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                     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