Skip to content

Instantly share code, notes, and snippets.

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
public class Count implements Runnable {
private static long processedTime = 0;
File file;
public Count(File fileName) {
import akka.Done
import akka.actor.Actor.Receive
import akka.actor.{Actor, ActorContext, ActorSystem, Props}
import akka.pattern.ask
import akka.routing.RoundRobinPool
import akka.util.Timeout
import scala.concurrent.Future
import scala.concurrent.duration._
import scala.io.Source
import scala.language.postfixOps