cubiche / async

    /**

     * Test reject.

     */

    public function testReject()

    {

        $this

            ->given(

                $reason = new \Exception(),

                $rejectCallback = $this->delegateMock(),

                /** @var \Cubiche\Core\Async\Promise\ObservableResolver $resolver */

                $resolver = $this->newTestedInstance(null, $rejectCallback)

            )

            ->when($resolver->reject($reason))

            ->then()

                ->delegateCall($rejectCallback)

                    ->withArguments($reason)

                    ->once()

        ;

    }

    /**

     * Test notify.

    /**

     * @param callable $when

     */

    protected function innerFailureTest(callable $when)

    {

        $this

            ->given(

                $reason = new \Exception(),

                $callback = $this->delegateMockWithException($reason),

                $rejectCallback = $this->delegateMock()

            )

            ->when($when($callback, $rejectCallback))

                ->then()

                ->delegateCall($rejectCallback)

                    ->withArguments($reason)

                    ->once()

            ;

    }

}