aboutsummaryrefslogtreecommitdiff
path: root/flow-samples/terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala
diff options
context:
space:
mode:
Diffstat (limited to 'flow-samples/terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala')
-rw-r--r--flow-samples/terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala19
1 files changed, 19 insertions, 0 deletions
diff --git a/flow-samples/terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala b/flow-samples/terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala
new file mode 100644
index 0000000..6b06206
--- /dev/null
+++ b/flow-samples/terminal/src/main/scala/com/github/jodersky/flow/samples/terminal/ConsoleReader.scala
@@ -0,0 +1,19 @@
+package com.github.jodersky.flow.samples.terminal
+
+import akka.actor._
+
+case object Read
+case class ConsoleInput(in: String)
+class ConsoleReader extends Actor {
+ import context._
+
+ def receive = {
+ case Read => read()
+ }
+
+ def read() = {
+ val in = Console.readLine()
+ parent ! ConsoleInput(in)
+ }
+
+} \ No newline at end of file