graze / parallel-process

        $this->assertTrue($hit);

    }

    public function testOnSuccessSetterIsCalledOnSuccessfulProcess()

    {

        $process = Mockery::mock(Process::class);

        $process->shouldReceive('stop');

        $process->shouldReceive('isStarted')->andReturn(true);

        $process->shouldReceive('isRunning')->andReturn(false);

        $process->shouldReceive('start')->atLeast()->once();

        $process->shouldReceive('isSuccessful')->once()->andReturn(true);

        $hit = false;

        $pool = new Pool();

        $this->assertSame(

            $pool,

            $pool->setOnSuccess(function ($proc) use ($process, &$hit) {

                $this->assertEquals($proc, $process);

                $hit = true;

            })

        );

        $pool->add($process);

        $pool->run(0);

        $this->assertTrue($hit);

    }

    public function testOnFailureSetterIsCalledForErroredProcess()

    {

        $this->assertTrue($hit);

    }

    public function testOnFailureSetterIsCalledForErroredProcess()

    {

        $process = Mockery::mock(Process::class);

        $process->shouldReceive('stop');

        $process->shouldReceive('isStarted')->andReturn(true);

        $process->shouldReceive('isRunning')->andReturn(false);

        $process->shouldReceive('poll')->andReturn(false);

        $process->shouldReceive('start')->atLeast()->once();

        $process->shouldReceive('isSuccessful')->once()->andReturn(false);

        $hit = false;

        $pool = new Pool();

        $this->assertSame(

            $pool,

            $pool->setOnFailure(function ($proc) use ($process, &$hit) {

                $this->assertEquals($proc, $process);

                $hit = true;

            })

        );

        $pool->add($process);

        $pool->run(0);

        $this->assertTrue($hit);

    }

    public function testOnProgressSetterIsCalledDuringProcessRun()

    {