node.js async.eachSeries l'appel final de rappel trop tôt

C'est ce que je veux: j'ai un grand tableau intitulé résultats. Chaque élément de ce tableau je veux mettre dans mon itération de la fonction et de l'enregistrer dans mon mongoDB (j'ai omis quelques étapes ici qui ne sont pas importants). Après chacun de ces éléments a été enregistré dans la base de données (ou refusé) je veux de la console.le journal pour afficher "Tout fait". Malheureusement, Tous les fait s'affiche presque immédiatement après l'appel de la série tandis que tout le reste est toujours en cours de traitement. Comment puis-je faire de ce droit?

Je suis à l'aide de la mangouste avec un modèle appelé "lumière" et pour des raisons de lisibilité j'ai omis tous tre des messages à partir du code. Je utiliser un nœud-async pour la eachSeries partie

var async = require('async');    
var results = [very big array]
var iteration = function(row,callbackDone) {
  light.find({data: row.data}, function (err,entry) {
    if(entry.length) {
      callbackDone();
      return console.log(entry + ' already exists');
    }
    var newEntry = new light(row);
    newEntry.save(function (err,doc) {
      console.log(entry + ' saved');
      callbackDone();
    });
  });
};

async.eachSeries(results,iteration, function (err) {
  console.log('All done');
});
Essayez d'ajouter certains d'erreur enregistreurs (if (err) console.log(err);).
J'ai enlevé l'erreur enregistreurs pour des raisons de lisibilité. désolé si je n'étais pas clair. Le tableau facilement a+ de 100 entrées, les mangoustes, les opérations de travail parfaitement, mais les enregistre tous se passera après la console.log ("tout fait") a été affiché. J'ai besoin d'un moyen d'afficher "tout fait" exactement après que tous les éléments de mon tableau ont été traitées

OriginalL'auteur elmalto | 2014-02-12

  1. 4

    (Une réponse, pas un commentaire, parce que le texte était trop long...)

    Je suis en utilisant async pour quelque chose de trop et votre question me laisse perplexe. J'ai essayé le code ci-dessous avant d'obtenir les résultats encore plus bas. Il a bien fonctionné pour moi. (async 0.2.9). Même en changeant mon délai d'attente des retards à 0.

    La seule chose qui semblait étrange était le if(entry.length) imprimé console de l'information après le rappel. Si vous avez été d'obtenir beaucoup de "existe déjà" messages que j'ai pu voir potentiellement venir plus tard - mais cela ne ressemble pas à ce que vous décrivez.

    var async = require('async');  
var console = require('console');
var results = [ ];
results.push( {id:1,data:'a'} );
results.push( {id:2,data:'b'} );
results.push( {id:3,data:'c'} );
results.push( {id:4,data:'d'} );
function doFind( obj, callback ) {
setTimeout( function() {
console.log( "finding id=" + obj.data.id );
obj.data.length = obj.data.id % 2;
callback( null, obj.data );
}, 500 );
}
function light( obj ) {
this.id = obj.id;
this.data = obj.data;
this.save = function( callback ) {
setTimeout( function() {
console.log( "saving id=" + obj.id );
callback( null, this );
}, 500 );
};
}
var iteration = function(row,callbackDone) {
doFind({data: row}, function (err,entry) {
if(entry.length) {
callbackDone(); 
return console.log( 'id=' + entry.id + ' already exists');
}
var newEntry = new light(row);
newEntry.save(function (err,doc) {
console.log( 'id=' + entry.id + ' saved');
callbackDone();
});
});
};
async.eachSeries(results, iteration, function (err) {
console.log('All done');
});

    Résultats

    finding id=1
id=1 already exists
finding id=2
saving id=2
id=2 saved
finding id=3
id=3 already exists
finding id=4
saving id=4
id=4 saved
All done
    ton exemple fonctionne parfaitement pour moi aussi, pour une raison que je ne pouvais pas résoudre mon problème. Je suis passé à un var stream = lumière.find({}).stream(); solution et stoppé le flux jusqu'à la async réponse est venue. Probablement un peu moche, mais ça fonctionne pour moi. Je vous remercie beaucoup pour votre participation!

    OriginalL'auteur clay