php - 如何订阅 rethinkdb PHP 驱动程序中的更改？

Question

我正在使用 Ratchet php 每秒检查 rethink db 表中所做的更改。
但是即使我编辑了文档，更改()也不会返回任何内容。我在这里做错了什么？

我确实引用了这篇文章:rethinkdb PHP-RQL changes

这就是我在 RethinkDB 中查询更改的方式

function fetchProduct() {
    $products = r\table("tableOne")->changes()->run($conn);

            foreach ($products as $product) {
               $p[] = $product;
            }

            return $p;

}

这就是我每秒通过 Rachet 检查更改的方式:

$count = 0;

loopy($server, $count);

function loopy($server, $count) {    

   $server->loop->addPeriodicTimer(1, 


     function ($timer) use ( &$server, &$count) {



         $count++;
            echo $count."\n";
            //test starts

            $product = fetchProduct();
            echo "<pre>";
            var_dump($product);
            //test ends

   });

}

但是即使在编辑文档时也没有返回数据。它还停止执行 Ratchet 中的循环。如果我删除了 changes()然后它将在 Ratchet 循环运行时每秒返回表中的所有文档。但我希望仅在进行更改时返回数据。我如何做到这一点？

Answer 1

我只是将迭代更改为这个并且它起作用了:

 foreach ($products as $product) {
            print_r($product);
        }