mainapp.scala

package cusin

import scalax.io._
import Resource._

import FileWriterBackend.xmlParserService
import FileWriterBackend.ParseLineRequest
import akka.actor.PoisonPill

object App {

  def main(args: Array[String]): Unit = {

    val fileName = "\\temp\\sampledata2.txt"

    implicit val codec = Codec.ISO8859
    val in: Input = Resource.fromURL("file://" + fileName)
    
     val start = System.nanoTime()

    // send lines starting with <? to the xmlParser services
    in.lines().filter(_.startsWith("<?")).zipWithIndex.foreach { case (line, no) ⇒ xmlParserService ! ParseLineRequest(no, line) }

    Thread.sleep(1000);
    FileWriterBackend.xmlParserService ? PoisonPill
    val end = System.nanoTime()
    println((end - start) / 1000000000.0 )
    
  }

}