content: /*
   * Copyright 2015, 2024 StreamEx contributors
   *
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  
  package one.util.streamex;
  
  import org.junit.Test;
  
  import java.util.List;
  import java.util.Spliterator;
  import java.util.Spliterators;
  import java.util.concurrent.atomic.AtomicInteger;
  import java.util.stream.StreamSupport;
  
  import static one.util.streamex.TestHelpers.checkSpliterator;
  import static org.junit.Assert.assertEquals;
  import static org.junit.Assert.assertTrue;
  
  public class UnknownSizeSpliteratorTest {
      @Test
      public void testSplit() {
          List<Integer> input = IntStreamEx.range(100).boxed().toList();
          Spliterator<Integer> spliterator = new UnknownSizeSpliterator.USOfRef<>(input.iterator());
          assertEquals(Long.MAX_VALUE, spliterator.estimateSize());
          AtomicInteger count = new AtomicInteger();
          assertTrue(spliterator.tryAdvance(count::addAndGet));
          assertTrue(spliterator.tryAdvance(count::addAndGet));
          assertEquals(1, count.get());
          assertEquals(Long.MAX_VALUE, spliterator.estimateSize());
          Spliterator<Integer> spliterator2 = spliterator.trySplit();
          assertTrue(spliterator.tryAdvance(count::addAndGet));
          assertTrue(spliterator2.tryAdvance(count::addAndGet));
          assertEquals(54, count.get());
      }
  
      @Test
      public void testRefSpliterator() {
          for (int size : new int[] { 1, 5, 100, 1000, 1023, 1024, 1025, 2049 }) {
              List<Integer> input = IntStreamEx.range(size).boxed().toList();
              checkSpliterator(String.valueOf(size), input, () -> new UnknownSizeSpliterator.USOfRef<>(input.iterator()));
          }
      }
  
      @Test
      public void testIntSpliterator() {
          for (int size : new int[] { 1, 5, 100, 1000, 1023, 1024, 1025, 2049 }) {
              int[] input = IntStreamEx.range(size).toArray();
              checkSpliterator(String.valueOf(size), IntStreamEx.of(input).boxed().toList(),
                  () -> new UnknownSizeSpliterator.USOfInt(Spliterators.iterator(Spliterators.spliterator(input, 0))));
          }
      }
  
      @Test
      public void testLongSpliterator() {
          for (int size : new int[] { 1, 5, 100, 1000, 1023, 1024, 1025, 2049 }) {
              long[] input = LongStreamEx.range(size).toArray();
              checkSpliterator(String.valueOf(size), LongStreamEx.of(input).boxed().toList(),
                  () -> new UnknownSizeSpliterator.USOfLong(Spliterators.iterator(Spliterators.spliterator(input, 0))));
          }
      }
  
      @Test
      public void testDoubleSpliterator() {
          for (int size : new int[] { 1, 5, 100, 1000, 1023, 1024, 1025, 2049 }) {
              double[] input = LongStreamEx.range(size).asDoubleStream().toArray();
              checkSpliterator(String.valueOf(size), DoubleStreamEx.of(input).boxed().toList(),
                  () -> new UnknownSizeSpliterator.USOfDouble(Spliterators.iterator(Spliterators.spliterator(input, 0))));
          }
      }
  
      @Test
      public void testAsStream() {
          List<Integer> input = IntStreamEx.range(100).boxed().toList();
          assertEquals(4950, StreamSupport.stream(new UnknownSizeSpliterator.USOfRef<>(input.iterator()), false)
                  .mapToInt(x -> x).sum());
          assertEquals(4950, StreamSupport.stream(new UnknownSizeSpliterator.USOfRef<>(input.iterator()), true).mapToInt(
              x -> x).sum());
  
          input = IntStreamEx.range(5000).boxed().toList();
          assertEquals(12497500, StreamSupport.stream(new UnknownSizeSpliterator.USOfRef<>(input.iterator()), false)
                  .mapToInt(x -> x).sum());
          assertEquals(12497500, StreamSupport.stream(new UnknownSizeSpliterator.USOfRef<>(input.iterator()), true)
                  .mapToInt(x -> x).sum());
      }
  }
  