first commit

src/main/scala/fr/natan/akkastreamfileprocessingapi/service/AkkaStreamFileProcessingImpl.scala

@@ -180,13 +180,13 @@ class AkkaStreamFileProcessingImpl extends AkkaStreamFileProcessing {
 
     val startTime: Long = System.currentTimeMillis()
 
-    val res : Future[IndexedSeq[Person]]= source
-      .filter((rowMap: Map[String, String])=>{
-        nconstList.contains(rowMap.getOrElse(key = "nconst",default = ""))
-      })
+    val res : Future[IndexedSeq[Person]]=
+      source
+        .filter((rowMaps: Map[String, String])=>{
+          nconstList.contains(rowMaps.get(key = "nconst"))
+        })
       .map((rowMap: Map[String, String])=>{
-        val person: Person = buildPersonModel(rowMap)
-        person
+       buildPersonModel(rowMap)
       })
       .runWith(Sink.collection)
       .andThen {