Как внести изменения () в возвращаемое значение rethinkdb, не останавливая другой процесс

Я использую драйвер PHP для переосмысления. Я подписываюсь на изменения из таблицы, используя changes() заявление.

Проблема в том, что, как только он начинает слушать, не запускается ни один другой процесс. Только этот процесс выполняется.

Я понимаю, как работает класс генератора. Использование yield вместо оператора return для поддержания цикла в рабочем состоянии. Но с использованием yield мне все еще нужно перебирать foreach для получения данных. Поскольку итерация никогда не заканчивается, как заставить другой процесс работать так же

Каков наилучший способ сделать это? Я использую неправильную итерацию?

Как я упоминал здесь, они советуют использовать каждый или toArray, чтобы предотвратить бесконечный цикл класса генератора, но в javascript.

Как мне сделать это в PHP?

https://www.rethinkdb.com/api/javascript/each/