Skip to content

Instantly share code, notes, and snippets.

@rogeralsing
Created March 26, 2016 18:34
Show Gist options
  • Save rogeralsing/0c6e8b97035cc03db4a2 to your computer and use it in GitHub Desktop.
Save rogeralsing/0c6e8b97035cc03db4a2 to your computer and use it in GitHub Desktop.
...
var jobs = db.GetJobs(..);
var aggregator = sys.ActorOf(Props.Create(() => new AggregatorActor(jobs.Count));
foreach(var job in jobs)
{
workerRouter.Tell(new JobMessage(job.Data, aggregator);
}
...
class AggregatorActor : ReceiveActor
{
public AggregatorActor(int jobCount)
{
Receive<JobDone>(msg => {
jobCount --;
if (jobCount == 0) //done
{
//Tell someone
}
});
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment