Comment renvoyer tous les flux à la fois d'une tâche gourmande avec plusieurs fichiers source?

Question

La tâche de gulp que j'ai écrite interrompt runSequence dans ma tâche principale de goulotte. Il doit fonctionner entre d'autres tâches, comme ceci:

runSequence(
... 
':build:prod:staticIndex', 
':build:prod:typeDocToMD', // << this is my task 
':build:prod:staticDocumentation', 
...etc 

Et la tâche après elle ne sera jamais exécutée. Ce qui me fait penser que ma tâche ne renvoie pas un seul flux ou le fait incorrectement.

Voici comment ma tâche ressemble:

gulp.task(':build:prod:typeDocToMD', (done: any) => { 
let taskNum: number = 0; 
    let streams = []; 
    let filesPath = [ 
    path.join(__CONFIG.TMPL_DOCS_PATH, '**/*.md') 
    ]; 
    glob(filesPath.toString(), function (er, files) { 
    taskNum = files.length - 1; 
    files.forEach((filename) => { 
     let stream = gulp.src(filename) 
     .pipe(addTypedoc()) // << this is the custom plugin I wrote 
     .pipe(gulp.dest(function (file) { 
      return file.base; 
     })); 
     stream.on('end',() => { 
     streams.push(stream); 
     if (streams.length === taskNum) { 
      gUtil.log('the end!'); 
      return merge(streams); 
     } 
     }); 
    }); 
    }); 
}); 

J'utilisé glob pour obtenir récursive tous les fichiers du dossier md. Et j'ai utilisé merge-stream pour combiner tous les flux ensemble et retourner un seul.

Je reçois la «fin! message enregistré mais gulp n'atteint jamais la tâche suivante après cela.

Ai-je raté quelque chose ici?

Merci d'avance pour votre aide!

Answer 1

OK, je viens de trouver une solution à cela, et il est ridiculement simple: utiliser l'argument de rappel de la tâche comme ceci:

if (streams.length === taskNum) { 
    gUtil.log('the end!'); 
    done(); 
} 

Maintenant, ça marche! Et je n'avais même pas besoin d'utiliser merge-stream après tout.