WyriHaximus / cakephp-async-orm

        $this->messenger = $messenger;

        $this->loop = $loop;

        $this->messenger->registerRpc('table.call', function (Payload $payload) {

            $deferred = new Deferred();

            $this->loop->futureTick(function () use ($payload, $deferred) {

                $this->handleTableCall($payload, $deferred);

            });

            return $deferred->promise();

        });

        $this->messenger->registerRpc('paginate', function (Payload $payload) {

            $deferred = new Deferred();

            return $deferred->promise();

        });

        $this->messenger->registerRpc('paginate', function (Payload $payload) {

            $deferred = new Deferred();

            $this->loop->futureTick(function () use ($payload, $deferred) {

                $this->handlePaginateCall($payload, $deferred);

            });

            return $deferred->promise();

        });

    }

    /**