diff --git a/src/main/scala/com/fulcrumgenomics/fastq/TrimFastq.scala b/src/main/scala/com/fulcrumgenomics/fastq/TrimFastq.scala index b9437f812..150da7085 100644 --- a/src/main/scala/com/fulcrumgenomics/fastq/TrimFastq.scala +++ b/src/main/scala/com/fulcrumgenomics/fastq/TrimFastq.scala @@ -58,7 +58,6 @@ class TrimFastq val progress = new ProgressLogger(this.logger, noun="records", verb="Wrote") val lengths = if (this.length.size == 1) List.fill(this.input.size)(this.length.head) else this.length - val sources = input.map(FastqSource(_)) val writers = output.map(FastqWriter(_)) while (allHaveNext(sources)) { diff --git a/src/test/scala/com/fulcrumgenomics/fastq/TrimFastqTest.scala b/src/test/scala/com/fulcrumgenomics/fastq/TrimFastqTest.scala index 4ea82f997..6b8a59bb2 100644 --- a/src/test/scala/com/fulcrumgenomics/fastq/TrimFastqTest.scala +++ b/src/test/scala/com/fulcrumgenomics/fastq/TrimFastqTest.scala @@ -133,7 +133,7 @@ class TrimFastqTest extends UnitSpec { r2Map("20x20").length shouldBe 15 } - it should "trim some reads and discard others with FASTQ specific lengths" in { + it should "trim each FASTQ independently to a FASTQ-specific length" in { val (r1, r2) = fqFiles val (r1Out, r2Out) = (makeTempFile("r1out.", ".fq"), makeTempFile("r2out.", ".fq")) new TrimFastq(input = Seq(r1, r2), output=Seq(r1Out, r2Out), length = Seq(10, 15), exclude = false).execute()