Как сделать асинхронный генератор в Node.js из сишной N-API?

Question

[Vitold S]

Итак, имеем сишный код дергающий периодический сallback с userdata,
и стоит задача превратить данный вызов в асинхронный генератор, что то вроде

for await (const item of napi.c_callback()) {
   console.log(item);
}

Каким образом это можно сделать? Есть ли где-то пример подобной реализации?

Comments

[monochromer]

Можете сделать минимальный пример с вызовом функции?

[Vitold S]

monochromer, да конечно (псевдокод без генерированного кода и проверки ошибок):

#define NAPI_VERSION 3
#include <node_api.h>

typedef cb_fn (void *)(int, void *));

void start_processing_routine(cb_fn callback, void *userdata) {
    for (int value = 0; value < 1000; i++) {
        callback(value, userdata);
    }
}

napi_value c_callback(napi_env env) {
    void *userdata = NULL;
    cb_fn callback;
    pthread_create(start_processing_routine, callback, userdata);
    // ... вот соответственно вопрос тут нужно передать такой callback, который заблокирует поток (мьютесом) и вто же время вернет в Node асинхроный итератор, который будет отпускать мьютекс и разрешать проворачивать поток через await ... код в start_processing_routine доступен только для чтения (дикая проприетарщина)

    return NULL;
}