m

index.ts

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

test.js

@@ -11,5 +11,5 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
 Object.defineProperty(exports, "__esModule", { value: true });
 const _1 = require(".");
 (() => __awaiter(void 0, void 0, void 0, function* () {
-    yield (0, _1.scheduleAsyncBwaMem)([['/Turbine-pool/LAL-T_RNAseq/fastq_fastp/231_LEB/R1.fq.gz', '/Turbine-pool/LAL-T_RNAseq/fastq_fastp/231_LEB/R2.fq.gz']], '/home/thomas/NGS/ref/ncbi/RNA/human_NM.fa', 'TEST', 'TEST', 'test/', console.log);
+    yield (0, _1.scheduleAsyncBwaMem)([['/Turbine-pool/LAL-T_RNAseq/fastq_fastp/231_LEB/R1.fq.gz', '/Turbine-pool/LAL-T_RNAseq/fastq_fastp/231_LEB/R2.fq.gz']], '/home/thomas/NGS/ref/ncbi/RNA/human_NM.fa', 'TEST', 'TEST', ['test/'], console.log);
 }))();

test.ts

@@ -3,6 +3,6 @@ import { scheduleAsyncBwaMem } from ".";
 (async()=>{
     await scheduleAsyncBwaMem(
         [['/Turbine-pool/LAL-T_RNAseq/fastq_fastp/231_LEB/R1.fq.gz','/Turbine-pool/LAL-T_RNAseq/fastq_fastp/231_LEB/R2.fq.gz']],
-        '/home/thomas/NGS/ref/ncbi/RNA/human_NM.fa', 'TEST', 'TEST', 'test/', console.log
+        '/home/thomas/NGS/ref/ncbi/RNA/human_NM.fa', 'TEST', 'TEST', ['test/'], console.log
     )
 })()