Home | History | Annotate | Download | only in stream
      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 org.openjdk.tests.java.util.stream;
     24 
     25 import org.testng.annotations.Test;
     26 
     27 import java.util.Arrays;
     28 import java.util.stream.Stream;
     29 
     30 import static org.testng.Assert.assertFalse;
     31 import static org.testng.Assert.assertTrue;
     32 
     33 @Test
     34 public class StreamParSeqTest {
     35 
     36     public void testParSeq() {
     37         Stream<Integer> s = Arrays.asList(1, 2, 3, 4).stream().parallel();
     38         assertTrue(s.isParallel());
     39 
     40         s = s.sequential();
     41         assertFalse(s.isParallel());
     42 
     43         s = s.sequential();
     44         assertFalse(s.isParallel());
     45 
     46         s = s.parallel();
     47         assertTrue(s.isParallel());
     48 
     49         s = s.parallel();
     50         assertTrue(s.isParallel());
     51     }
     52 }
     53