blob: c4401e7d3df1b34a1eea1360203f6b6749471b16 (
plain) (
blame)
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
|
package com.github.jodersky.flow.samples.terminal
import akka.actor._
import java.io.BufferedReader
import java.io.InputStreamReader
class ConsoleReader extends Actor {
import context._
import ConsoleReader._
def receive = {
case Read => read() match {
case Some(input) => parent ! ConsoleInput(input)
case None => parent ! EOT
}
}
def read(): Option[String] = {
val eot = 4
val line = Console.readLine
if (line == ":q") None else Some(line)
}
}
object ConsoleReader {
case object Read
case object EOT
case class ConsoleInput(in: String)
}
|
