Асинхронные вызовы супа - PullRequest
Новая
       70

Асинхронные вызовы супа

1 голос
/ 13 февраля 2020

Я работаю над простым расширением для Gnome DE и испытываю некоторые затруднения в связи с асинхронными вызовами Soup и событием l oop.

Вот что у меня есть: 

_httpSession = new Soup.Session();

let token = 'sometoken'
let url = 'someurl';
let _allData = [];
let elements = [1,2];

for (let el of elements) {
    let message = Soup.form_request_new_from_hash('GET', url + el, { access_token: token });
    _httpSession.queue_message(message, () => {
        if (message.status_code != Soup.KnownStatusCode.OK) {
            _error(message.status_code.toString());
        }
        try {
            message = JSON.parse(message.response_body.data).items;
        } catch (e) {
            _error(e.toString());
        }
        _allData = _allData.concat([el, message]);
    });
}

Учитывая приведенные выше асинхронные вызовы для l oop, как убедиться, что _allData.concat () была выполнена для всех итераций? Я хочу распечатать переменную _allData , но только при выполнении конкатенации для каждого el .

1 Ответ

2 голосов
/ 14 февраля 2020

Самый простой способ - это, вероятно, асинхронный шаблон c -wait: 

// Your request function can be turned into a Promise:
function requestFunc(session, message) {
    return new Promise((resolve, reject) => {
        session.queue_message(message, () => {
            try {
                if (message.status_code === Soup.KnownStatusCode.OK) {
                    let result = JSON.parse(message.response_body.data);

                    resolve(result);
                } else {
                    reject(new Error(message.status_code.toString()));
                }
            } catch (e) {
                reject(e);
            }
        });
    });
}

// Then you can await each in a loop
async function logRequestResults(session, url, token, elements) {
    try {
        let results = [];

        for (let el of elements) {
            let message = Soup.form_request_new_from_hash('GET', url + el, {
                access_token: token
            });

            let result = await requestFunc(session, message);

            results = results.concat([el, results.items]);
        }

        // Success; all requests completed
        log(results);
    } catch (e) {
        // An error occurred somewhere in the loop
        logError(e);
    }
}

// Using the function
_httpSession = new Soup.Session();

let token = 'sometoken'
let url = 'someurl';
let elements = [1,2];

logRequestResults(session, url, token, elements);

В зависимости от того, что вы на самом деле делаете со своими результатами, вы можете реорганизовать это. Важной частью является превращение шаблона func(something, () => {}) в Promise, который вы можете await в oop.

Также обратите внимание, что async функции неявно возвращают Promise, те, которые могут также можно использовать с await.

...