From cbe4c3741cea00944cb27ff8c9bb2cb0a3570066 Mon Sep 17 00:00:00 2001
From: Laurent Modolo <laurent.modolo@ens-lyon.fr>
Date: Wed, 29 Mar 2023 14:15:45 +0200
Subject: [PATCH] split r1 and r2

---
 src/main.nf | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/src/main.nf b/src/main.nf
index 9ebe5e7..1e27cd6 100644
--- a/src/main.nf
+++ b/src/main.nf
@@ -9,15 +9,14 @@ include { FASTKMERS } from "./modules/fastkmers.nf"
 
 Channel.fromPath( file(params.csv) )
                     .splitCsv(header: true)
-                    .map{row ->
+                    .multiMap{row ->
                         fastq_r1 = file("${row.r1}")
                         fastq_r2 = file("${row.r2}")
-                        meta = ['id': fastq_r1.simpleName, 'specie': row.specie, 'sex': row.sex]
-			println(row)
-                        [meta, [fastq_r1, fastq_r2]]
+                        r1: [['id': fastq_r1.simpleName, 'specie': row.specie, 'sex': row.sex, 'read': 'r1'], fastq_r1]
+                        r2: [['id': fastq_r1.simpleName, 'specie': row.specie, 'sex': row.sex, 'read': 'r2'], fastq_r2]
                     }
                     .set{ fastq }
 
 workflow {
-  FASTKMERS(fastq)
+  FASTKMERS(fastq.r1.mix(fastq.r2))
 }
-- 
GitLab