forked from petabridge/akka-bootcamp
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Program.cs
48 lines (40 loc) · 1.57 KB
/
Program.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
using System;
using Akka.Actor;
namespace WinTail
{
class Program
{
public static ActorSystem MyActorSystem;
static void Main(string[] args)
{
// make an actor system
MyActorSystem = ActorSystem.Create("MyActorSystem");
PrintInstructions();
// make our first actors!
IActorRef consoleWriterActor = MyActorSystem.ActorOf(Props.Create(() => new ConsoleWriterActor()),
"consoleWriterActor");
IActorRef consoleReaderActor =
MyActorSystem.ActorOf(Props.Create(() => new ConsoleReaderActor(consoleWriterActor)),
"consoleReaderActor");
// tell console reader to begin
consoleReaderActor.Tell("start");
// blocks the main thread from exiting until the actor system is shut down
MyActorSystem.AwaitTermination();
}
private static void PrintInstructions()
{
Console.WriteLine("Write whatever you want into the console!");
Console.Write("Some lines will appear as");
Console.ForegroundColor = ConsoleColor.DarkRed;
Console.Write(" red ");
Console.ResetColor();
Console.Write(" and others will appear as");
Console.ForegroundColor = ConsoleColor.Green;
Console.Write(" green! ");
Console.ResetColor();
Console.WriteLine();
Console.WriteLine();
Console.WriteLine("Type 'exit' to quit this application at any time.\n");
}
}
}