WyriHaximus / cakephp-async-orm

        ]));

    }

    protected function waitForPaginateCall($tableName, $params, $settings)

    {

        $deferred = new Deferred();

        $this->loop->addPeriodicTimer(

            0.1,

            function (TimerInterface $timer) use ($deferred, $tableName, $params, $settings) {

                if ($this->pool instanceof PoolInterface) {

                    $timer->cancel();

                    $deferred->resolve($this->paginateCall($tableName, $params, $settings));

                }

            }

        );

        return $deferred->promise();

    }

    /**

     * @inheritDoc

     * @param  array            $arguments

     * @return PromiseInterface

     */

    protected function waitForPoolCall($tableName, $function, array $arguments)

    {

        $deferred = new Deferred();

        $this->loop->addPeriodicTimer(

            0.1,

            function (TimerInterface $timer) use ($deferred, $tableName, $function, $arguments) {

                if ($this->pool instanceof PoolInterface) {

                    $timer->cancel();

                    $deferred->resolve($this->call($tableName, $function, $arguments));

                }

            }

        );

        return $deferred->promise();

    }

}