nick318

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>project</groupId>
    <artifactId>autotests</artifactId>
    <version>1.0-SNAPSHOT</version>

nick318

package com.company;

import io.qameta.allure.Step;

import java.io.*;

/**
 * Class for copy logs into Allure
 */
public class AllurePrintStream extends PrintStream

nick318

@Test
    public void correctValuesForConcurrentHasNext() throws ExecutionException, InterruptedException {

        int exceptionCount = 0;
        for (int i = 0; i <5000; i++) {
            Iterator<Integer> syncIterator = new SyncIterator<Integer>(
                Stream.iterate(0, j -> j + 1).limit(200)
                    .collect(toList())
                    .iterator());
            CountDownLatch startSignal = new CountDownLatch(1);

nick318

    @Test
    public void correctValuesForConcurrentNext() throws ExecutionException, InterruptedException {

        for (int i = 0; i < 5000; i++) {
            final Iterator<String> syncIterator = new SyncIterator<>(
                new ListOf<>("a", "b")
                    .iterator());
            final CountDownLatch startSignal = new CountDownLatch(1);
            final ExecutorService executors = Executors.newFixedThreadPool(2);
            final Future<String> letter = executors.submit(() -> {

nick318

@Test
    public void doubleCall() throws IOException {
        Md5DigestOf md5DigestOf = new Md5DigestOf(
            new InputOf(
                new ResourceOf(
                    "org/cactoos/io/DigestEnvelope.class"
                ).stream()
            )
        );

nick318

@Test
    public void correctValuesForConcurrentHasNext() throws ExecutionException, InterruptedException {

        int exceptionCount = 0;
        for (int i = 0; i <5000; i++) {
            Iterator<Integer> syncIterator = new SyncIterator<Integer>(
                Stream.iterate(0, j -> j + 1).limit(200)
                    .collect(toList())
                    .iterator());
            CountDownLatch startSignal = new CountDownLatch(1);