Browse Source

first commit

placidenduwayo 1 year ago
parent
commit
12ef7fb335

+ 1
- 1
src/main/scala/fr/natan/akkastreamfileprocessingapi/service/AkkaStreamFileProcessing.scala View File

4
 
4
 
5
 trait AkkaStreamFileProcessing {
5
 trait AkkaStreamFileProcessing {
6
 
6
 
7
-  def getAllMovies(): List[Movie]
7
+  def getAllMovies()
8
   def getMoviesByTitle (movieTitle: String)
8
   def getMoviesByTitle (movieTitle: String)
9
 }
9
 }

+ 1
- 1
src/main/scala/fr/natan/akkastreamfileprocessingapi/service/AkkaStreamFileProcessingImpl.scala View File

20
   implicit val actorSystem: ActorSystem = ActorSystem("AkkaStreamActor")
20
   implicit val actorSystem: ActorSystem = ActorSystem("AkkaStreamActor")
21
   implicit val logger: Logger = Logger(LoggerFactory.getLogger(this.getClass))
21
   implicit val logger: Logger = Logger(LoggerFactory.getLogger(this.getClass))
22
 
22
 
23
-  override def getAllMovies(): List[Movie] = {
23
+  override def getAllMovies() = {
24
 
24
 
25
     val source: Source[String, NotUsed] = buildAndValidateSource(inputFile = titleBasics)
25
     val source: Source[String, NotUsed] = buildAndValidateSource(inputFile = titleBasics)
26
     val sink: Sink[Movie, Future[Done]] = buildSink(logger = logger)
26
     val sink: Sink[Movie, Future[Done]] = buildSink(logger = logger)

Powered by TurnKey Linux.