Задайте функцию, чтобы вызвать, когда новые данные будут получены на DataQueue
задает функциональный listener
= afterEach(queue
, funtocall
)funtocall
выполнить каждый раз queue
получает новые данные. Можно задать несколько различных функций, чтобы вызвать, потому что каждый вызов afterEach
создает новый прослушиватель на очереди. Если вы хотите задать другую функцию, вызвать afterEach
снова. Удалить регистрацию функции с queue
, удалите возвращенный listener
объект.
Необходимо вызвать afterEach
в том же процессе, где вы создали очередь данных, в противном случае происходит ошибка. После вызова afterEach
, любые текущие данные в очереди сразу отправлены предоставленной функции.
event.listener
| parallel.pool.DataQueue
| parallel.pool.PollableDataQueue
| parfor
| poll
| send