m

index.js

@@ -191,8 +191,8 @@ const asyncBwaMemWorker = (args) => __awaiter(void 0, void 0, void 0, function*
     const { refPath, reads, runName, libName, outputDir, onData } = args;
     yield asyncBwaMem(refPath, reads, runName, libName, outputDir, onData);
 });
-const scheduleAsyncBwaMem = (allReads, refPath, runName, libName, outputDir, onData) => __awaiter(void 0, void 0, void 0, function* () {
+const scheduleAsyncBwaMem = (allReads, refPath, runName, libName, allOutputDir, onData) => __awaiter(void 0, void 0, void 0, function* () {
     const q = fastq.promise(asyncBwaMemWorker, 1);
-    yield Promise.all(allReads.map(reads => q.push({ refPath, reads, runName, libName, outputDir, onData })));
+    yield Promise.all(allReads.map((reads, i) => q.push({ refPath, reads, runName, libName, outputDir: allOutputDir[i], onData })));
 });
 exports.scheduleAsyncBwaMem = scheduleAsyncBwaMem;

index.ts

@@ -202,12 +202,11 @@ const scheduleAsyncBwaMem = async (
   refPath   : string,
   runName   : string,
   libName   : string,
-  outputDir : string,
+  allOutputDir : string,
   onData    : Function
 ) => {
   const q: queueAsPromised<Task> = fastq.promise(asyncBwaMemWorker, 1)
-  await Promise.all(allReads.map(reads => q.push({refPath, reads, runName, libName, outputDir, onData})))
+  await Promise.all(allReads.map((reads,i) => q.push({refPath, reads, runName, libName, outputDir:allOutputDir[i], onData})))
 }
 
-
 export { asyncBwaMem, writeSequence, makeReference, scheduleAsyncBwaMem }