vfd-uav/src/main/scala/vfd/uav/DummyConnection.scala


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

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 akka.actor.actorRef2Scala

class DummyConnection extends Actor with Connection {
  import context._

  var time = 0.0
  val messageInterval = FiniteDuration(50, MILLISECONDS)

  def flightData(time: Double) = {
    new Array[Byte](10)
  }

  override def preStart() = {
    context.system.scheduler.schedule(messageInterval, messageInterval) {
      time += messageInterval.toMillis
      clients foreach (_ ! flightData(time))
    }
  }

  def receive = {
    case Connection.Register => register(sender)
    case Terminated(client) => unregister(client)
  }

}

object DummyConnection {
  def apply = Props(classOf[DummyConnection])
}