cubiche / async

    /**

     * Test notify.

     */

    public function testNotify()

    {

        $this

            ->given(

                /** @var \Cubiche\Core\Async\Promise\DeferredInterface $deferred */

                $deferred = $this->newDefaultTestedInstance(),

                $onNotify = $this->delegateMock()

            )

            ->when(function () use ($deferred, $onNotify) {

                $deferred->promise()->then(null, null, $onNotify);

                $deferred->notify('foo');

            })

            ->then()

                ->delegateCall($onNotify)

                    ->withArguments('foo')

                    ->once()

            ;

    }

    /**

     * @param DeferredInterface $deferred

    /**

     * Test notify.

     */

    public function testNotify()

    {

        $this

            ->given(

                $promise = $this->newDefaultTestedInstance(),

                $onNotify = $this->delegateMock()

            )

            ->when(function () use ($promise, $onNotify) {

                $promise->then(null, null, $onNotify);

                $this->notify('foo');

            })

            ->then()

                ->delegateCall($onNotify)

                    ->withArguments('foo')

                    ->once()

        ;

    }

    /**

     * {@inheritdoc}