aboutsummaryrefslogtreecommitdiff
path: root/mavigator-uav/src/main/scala/mavigator/uav/Uav.scala
diff options
context:
space:
mode:
authorJakob Odersky <jakob@odersky.com>2016-02-04 22:57:01 -0800
committerJakob Odersky <jakob@odersky.com>2016-02-04 22:57:01 -0800
commitfce963dab70b163a79cb52dff4bac3dfd32c5f37 (patch)
treed28c88ce9f5432e5ed01407689153c297ea72be0 /mavigator-uav/src/main/scala/mavigator/uav/Uav.scala
parentb57a8c710d94ab6ce35fbbb0b9fc00649792e4be (diff)
downloadmavigator-fce963dab70b163a79cb52dff4bac3dfd32c5f37.tar.gz
mavigator-fce963dab70b163a79cb52dff4bac3dfd32c5f37.tar.bz2
mavigator-fce963dab70b163a79cb52dff4bac3dfd32c5f37.zip
move mock connection to stream (performance is really bad)
Diffstat (limited to 'mavigator-uav/src/main/scala/mavigator/uav/Uav.scala')
-rw-r--r--mavigator-uav/src/main/scala/mavigator/uav/Uav.scala3
1 files changed, 2 insertions, 1 deletions
diff --git a/mavigator-uav/src/main/scala/mavigator/uav/Uav.scala b/mavigator-uav/src/main/scala/mavigator/uav/Uav.scala
index a1ef333..37f94b6 100644
--- a/mavigator-uav/src/main/scala/mavigator/uav/Uav.scala
+++ b/mavigator-uav/src/main/scala/mavigator/uav/Uav.scala
@@ -1,6 +1,7 @@
package mavigator
package uav
+import mock._
import akka._
import akka.actor._
import akka.util._
@@ -14,7 +15,7 @@ class Uav(system: ExtendedActorSystem) extends Extension {
val t = scala.concurrent.duration.FiniteDuration(100, "ms")
Flow.fromSinkAndSource(
Sink.ignore,
- Source.tick(t,t, ByteString("hello world"))
+ (new MockConnection(0,0,1)).data
)
}