Discussion :

[ac/dc]

Bonjour,

J'utilise async.queue pour réceptionner des valeurs, qu'il faut traiter dans l'ordre de réception.

J'ai donc :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
queue = async.queue(traiterDonnees, 1);
queue.push(donnee, function (err) {});
 
function traiterDonnees (data, callback) {
...
callback();
}

Est-ce qu'il est possible d'utiliser ce mécanisme avec des promises ?

Merci

[Gnuum]

Désolé de répondre un peu tard.
Je ne sais pas si c'est ce que tu veux exactement, mais tu peux faire comme ça a priori:

Code JavaScript :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
var queueProcessing = new Promise(function(resolve, reject) {
  var queue = async.queue(traiterDonnees, 1);
 
  queue.drain = function() {
    resolve();
  };
 
  queue.push(donnee, function (err) {
    reject(err);
  });
  // ... 
 
  function traiterDonnees (data, callback) {
    // ...
    callback();
  }
}).then(function() {
  // ...
});
 
return queueProcessing;

Ce code suppose que tous tes push se font de manière synchrone et que tous tes processus sont asynchrones. De plus, il suppose également qu'une fois que ta queue est traitée une première fois, tu n'en a plus besoin.
Cependant, si c'est le cas, tu n'as certainement pas utilisé le bon composant async car le but de la queue est d'attendre des messages et de les processer. Si il n'y a pas de message, la queue attend, sinon elle les traite et s'il y en a trop, elle les stocke en attendant de pouvoir les traiter. Elle n'a pas forcément de fin.
Pense à utiliser un eachOfLimit en priorité si tu en attends un comportement avec un début et une fin clairement identifiés.

Autre possibilité, si une des données traitée doit mettre fin à la queue:

Code JavaScript :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
var queueProcessing = new Promise(function(resolve, reject) {
  var queue = async.queue(traiterDonnees, 1);
 
  queue.push(donnee, function (err) {
    reject(err);
  });
  // ... 
 
  function traiterDonnees (data, callback) {
    // ...
    if (data === conditionDeSortie) {
      resolve();
    }
    // ...
    callback();
  }
}).then(function() {
  // ...
});
 
return queueProcessing;

[ac/dc]

OK merci de ta réponse.
A priori tout n'est pas 'Promise' compatible

[Watilin]

Ici il y a une fonction promisify basée sur la bibliothèque Q qui semble capable d’adapter n’importe quelle fonction asynchrone de Node. Ça peut peut-être t’intéresser.

[Gnuum]

OK merci de ta réponse.
A priori tout n'est pas 'Promise' compatible

Je ne pense pas que ce soit une question de compatibilité. Les promesses servent à chaîner un flux asynchrone en le gardant plat (contrairement aux callbacks qui s'imbriquent les unes dans les autres).
En l'occurrence, il est tout à fait possible que ce que tu souhaites faire ne corresponde pas à cette utilisation.
Si tu me précises vraiment plus en détail ce que tu attends de ce code, je pourrais mieux te conseiller.