package test.sql.ru;

import java.util.stream.IntStream;

import org.junit.Assert;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;

public class FindFirstFindAnyTest {
    
    static final int ITERATIONS = 1000;
    
    @BeforeEach
    public void before(TestInfo testInfo) {
        String name = testInfo.getDisplayName();
        System.out.printf("Test '%s' started%n", name);
    }
    
    @AfterEach
    public void after(TestInfo testInfo) {
        String name = testInfo.getDisplayName();
        System.out.printf("Test '%s' finished%n", name);
    }
    
    @Test
    @DisplayName("Sequential")
    public void testStreamSequential() {
        int matchCount = 0;

        for (int i = 0; i < ITERATIONS; i++) {
            int any = getIntStream(false).findAny().getAsInt();
            int fst = getIntStream(false).findFirst().getAsInt();
            Assert.assertEquals(any, fst);
            
            if (any == fst) {
                matchCount++;
            }
        }
        
        Assert.assertEquals(matchCount, ITERATIONS);
    }

    @Test
    @DisplayName("Parallel")
    public void testStreamParallel() {
        int matchCount = 0;
        
        for (int i = 0; i < ITERATIONS; i++) {
            int any = getIntStream(true).findAny().getAsInt();
            int fst = getIntStream(true).findFirst().getAsInt();
            
            if (any == fst) {
                matchCount++;
            }
        }
        
        Assert.assertNotEquals(matchCount, ITERATIONS);
    }
    
    static IntStream getIntStream(boolean parallel) {
        IntStream stream = 
            IntStream.rangeClosed(Integer.MIN_VALUE, Integer.MAX_VALUE);
        
        return parallel ? stream.parallel() : stream;
    }
}