first commit

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

@@ -100,7 +100,7 @@ class AkkaStreamFileProcessingImpl extends AkkaStreamFileProcessingFuture {
     val finalFuture: Future[IndexedSeq[Person]] =
       tvSerieIDFuture.andThen({
         case Success(value: Option[String]) =>
-          logger.info(s"TvSerie ID: $value")
+          logger.info(s"TvSerie ID: ${value.get}")
           logger.info(s"STEP 1/3 END, elapsed time:${(System.currentTimeMillis() - start1) / 1000} sec")
 
       })
@@ -113,7 +113,7 @@ class AkkaStreamFileProcessingImpl extends AkkaStreamFileProcessingFuture {
             )
             listPersonIDsFuture.andThen({
               case Success(value) =>
-                value.foreach((personID: Option[String]) => logger.info(s"Person ID:$personID"))
+                value.foreach((personID: Option[String]) => logger.info(s"Person ID:${personID.get}"))
                 logger.info(s"STEP 2/3 END, elapsed time:${(System.currentTimeMillis() - start2) / 1000} sec")
             })
               .flatMap({
@@ -142,7 +142,7 @@ class AkkaStreamFileProcessingImpl extends AkkaStreamFileProcessingFuture {
     tvSerieIdFuture.andThen({
       case Failure(exception) => logger.error(s"${exception.printStackTrace()}")
       case Success(value: Option[String]) =>
-        logger.info(s"$value")
+        logger.info(s"${value.get}")
         logger.info(s"STEP 1/3 END, elapsed time:${(System.currentTimeMillis() - start1) / 1000} sec")
 
     })
@@ -155,7 +155,7 @@ class AkkaStreamFileProcessingImpl extends AkkaStreamFileProcessingFuture {
           listOfPersonsIDsFuture.andThen({
             case Failure(exception) => logger.error(s"${exception.printStackTrace()}")
             case Success(value: IndexedSeq[Option[String]]) =>
-              value.foreach((personID: Option[String]) => logger.info(s"Person ID:$personID"))
+              value.foreach((personID: Option[String]) => logger.info(s"Person ID:${personID.get}"))
               logger.info(s"STEP 2/3 END, elapsed time:${(System.currentTimeMillis() - start2) / 1000} sec")
           })
             .flatMap({