Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val epubs: Stream[File]
- val system = ActorSystem("reader-thing")
- val processor = system.actorOf(Props(classOf[FixedNumberOfChildren], 12))
- epubs.foreach{ epub =>
- val isbn = epub.getIsbn
- processor ! ProcessEpub(epub, isbn, writeToFile)
- }
- processor ! Fin
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement