2

Использую вызов асинхронных функций внутри асинхронных функций.
Необходимо записывать результат работы всех функций в callback асинхронной функции, в которой вызываются остальные.

Не могу понять куда приткнуть этот callback. В варианте, который в коде, в callback передаются данные после каждого их добавления, а требуется передать сразу все данные.

Если ставить callback в другой строке, то он "вылетает" из выполнения асинхронных функций и выполняется раньше, чем придут данные (что ожидаемо).

Как правильно обернуть функцию, чтобы callback не формировался (если это верный термин), пока не будут записаны все данные?

sendStudentTable: function (discipline, faculty, course, firstDate, lastDate, callback) {
        var dataval = [];
        var student = require('./createStudent');
        this.findAll().then(function (data) {
            if (!data) {
                callback(null, "Таблица пустая");
            } else {

                 data.forEach(function (item, i, data) {

                    student.getDiscipline(data[i].dataValues.uniqID, function (disc, err) {

                        if (err){
                            callback(null, "ошибка в поиске дисциплины");
                        } else {

                            if (discipline == disc) {

                                student.getSource(data[i].dataValues.uniqID, function (source, err) {

                                    if (err){
                                         callback (null, "ошибка в чём-то");
                                    } else {

                                        if (source.faculty == faculty && source.course == course) {
                                             dataval.push(data[i].dataValues.name);
                                             callback(dataval, null);
                                        }
                                    }
                                })
                            }
                        }
                    });
                 });
            }
        });
    }
4
  • @Doofy подправил по отступам в вебшторме. Не знаю стало ли особо читабельнее.
    – xd720p
    14 июн 2016 в 23:05
  • Поправил вопрос. Если всё верно, внесите правку
    – Doofy
    15 июн 2016 в 0:09
  • @Doofy посмотрел вашу правку, внёс изменения. Спасибо за помощь в оформлении. Ещё было бы интересно понять как правильно обернуть callback:)
    – xd720p
    15 июн 2016 в 7:25
  • Используйте Promise
    – zhenyab
    15 июн 2016 в 7:54

2 ответа 2

2

Почему у вас this.findAll возвращает обещание (Promise), а student.getDiscipline требует callback? Я бы рекомендовал вам привести ваш код к одному знаменателю. И лучше бы это были обещания, а не колбэки.

Причина предпочтительности обещаний - их можно комбинировать, и они защищены от повторного вызова.

Вот мой старый ответ, где расписано про комбинирование обещаний: Последовательное выполнение JSONP. Там комбинирование обещаний рассматривается для ajax-запросов - но заменить их на любой другой тип запросов не трудно.

Единственное значимое отличие - вместо $.when(...) надо использовать Promise.all([...]) (внимание на литерал массива), а вместо $.when.apply($, ...) можно написать просто Promise.all(...).

1
  • Здесь findAll() это функция sequelize, которая работает с Promises. Все функции у меня написаны на коллбэках, получается, что все надо переписывать на обещания.
    – xd720p
    15 июн 2016 в 9:03
2

В данном случае нужно дождаться, пока завершаться все асинхронные функции, запущенные в цикле. После завершения всех функций dataval будет содержать все значения, т.к. определен глобально относительно getDiscipline. Можно подсчитать, сколько функций было выполнено, основываясь на количестве значений в data.

// определить где-то снаружи getDiscipline
var totalFuncs = data.length;
var doneFuncs = 0;

// это завершающий код, после выполнения условий
doneFuncs += 1;

// эта функция последняя
if(doneFuncs == totalFunc) {
  callback(dataval); 
}

Замечания:

  • Для управления потоком асинхронных операций удобно использовать специально предназначенные библиотеки вроде async
  • Для работы со значениями, которые будут доступны в будущем можно использовать Promise, тогда чтобы собрать все значения можно использовать Promise.all([..]).then(..)
  • У вас не соблюдается соглашение об использовании callback функций, обычно используется форма callback(err, value)
7
  • Считать функции основываясь на количестве значений не выйдет, потому что doneFuncs заполнится ещё до получения данных. И когда первый раз попадём в финальное условие, то doneFuncs == totalFuncs. Пытался делать async, тоже не вышло, видимо, не до конца разобрался в нём.
    – xd720p
    15 июн 2016 в 8:46
  • Почему заполниться до получения? В том и смысл, что увеличивать его надо после получения, в этом месте: if (source.faculty == faculty && source.course == course) { // тут dataval.push(data[i].dataValues.name); doneFuncs += 1; }
    – pitersky
    15 июн 2016 в 8:52
  • Так ведь не все записи из data соответствуют этому условию. В data, допустим, 5 записей, а соответствуют 3. Значит doneFunc никогда не будет 5
    – xd720p
    15 июн 2016 в 8:59
  • А, ну да. Тогда не проще ли data отфильтровать используя Array.filter по этому условию var r = data.filter(... твой код, где заменить финальный if на return - условие) -> останутся только значения подходящие под условие
    – pitersky
    15 июн 2016 в 9:08
  • Интересный вариант, но как тогда передать r в коллбэк после фильтрации?
    – xd720p
    15 июн 2016 в 9:15

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.