diff options
Diffstat (limited to 'vfd-uav/src/main/scala/vfd/uav/DummyConnection.scala')
-rw-r--r-- | vfd-uav/src/main/scala/vfd/uav/DummyConnection.scala | 23 |
1 files changed, 11 insertions, 12 deletions
diff --git a/vfd-uav/src/main/scala/vfd/uav/DummyConnection.scala b/vfd-uav/src/main/scala/vfd/uav/DummyConnection.scala index 991a303..7cf7bb1 100644 --- a/vfd-uav/src/main/scala/vfd/uav/DummyConnection.scala +++ b/vfd-uav/src/main/scala/vfd/uav/DummyConnection.scala @@ -1,9 +1,13 @@ package vfd.uav +import java.util.concurrent.TimeUnit.MILLISECONDS + +import scala.concurrent.duration.FiniteDuration + import akka.actor.Actor +import akka.actor.Props import akka.actor.Terminated -import scala.concurrent.duration.FiniteDuration -import java.util.concurrent.TimeUnit._ +import akka.actor.actorRef2Scala class DummyConnection extends Actor with Connection { import context._ @@ -12,18 +16,11 @@ class DummyConnection extends Actor with Connection { val messageInterval = FiniteDuration(50, MILLISECONDS) def flightData(time: Double) = { - Connection.NewDataFrame(DataFrame( - math.sin(time/6000) * math.Pi, - math.sin(time/5050) * math.Pi/4, - time/5000 * 2 * math.Pi, - time/1000, - 22 - )) + new Array[Byte](10) } - override def preStart() = { - context.system.scheduler.schedule(messageInterval, messageInterval){ + context.system.scheduler.schedule(messageInterval, messageInterval) { time += messageInterval.toMillis clients foreach (_ ! flightData(time)) } @@ -36,5 +33,7 @@ class DummyConnection extends Actor with Connection { } - +object DummyConnection { + def apply = Props(classOf[DummyConnection]) +} |