blob: fe3ed86bcf077247e95fb81464cbfb0b7ee667a6 (
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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
package com.github.jodersky.flow
package samples.terminalstream
import akka.actor._
import akka.stream._
import akka.stream.stage._
import akka.stream.scaladsl._
import akka.util._
import scala.concurrent._
import scala.concurrent.duration._
import scala.util._
import akka.Done
import stream._
object Main {
final val Delay = FiniteDuration(500, MILLISECONDS)
implicit val system = ActorSystem("terminal-stream")
implicit val materializer = ActorMaterializer()
def main(args: Array[String]): Unit = {
import system.dispatcher
val serial: Flow[ByteString, ByteString, Future[Serial.Connection]] =
Serial().open("/dev/ttyACM0", SerialSettings(115200))
val printer: Sink[ByteString, _] = Sink.foreach[ByteString]{data =>
println("server says: " + data.decodeString("UTF-8"))
}
val ticker: Source[ByteString, _] = Source.tick(Delay, Delay, ()).scan(0){case (x, _) =>
x + 1
}.map{ x =>
println(x)
ByteString(x.toString)
}
val connection: Future[Serial.Connection] = ticker.viaMat(serial)(Keep.right).to(printer).run()
connection map { conn =>
println("Connected to " + conn.port)
readLine("Press enter to exit")
} recover { case err =>
println("Cannot connect: " + err)
} andThen { case _ =>
system.terminate()
}
}
}
|
