1 files changed, 31 insertions, 0 deletions
diff --git a/mavigator-uav/src/main/scala/mavigator/uav/Uav.scala b/mavigator-uav/src/main/scala/mavigator/uav/Uav.scala
new file mode 100644
index 0000000..a1ef333
--- /dev/null
+++ b/mavigator-uav/src/main/scala/mavigator/uav/Uav.scala
@@ -0,0 +1,31 @@
+package mavigator
+package uav
+
+import akka._
+import akka.actor._
+import akka.util._
+import akka.stream.scaladsl._
+
+class Uav(system: ExtendedActorSystem) extends Extension {
+
+  private lazy val config = system.settings.config.getConfig("mavigator.uav")
+
+  def connect(): Flow[ByteString, ByteString, NotUsed] = {
+    val t = scala.concurrent.duration.FiniteDuration(100, "ms")
+    Flow.fromSinkAndSource(
+      Sink.ignore,
+      Source.tick(t,t, ByteString("hello world"))
+    )
+  }
+
+}
+
+object Uav extends ExtensionId[Uav] with ExtensionIdProvider {
+
+  override def lookup = Uav
+
+  override def createExtension(system: ExtendedActorSystem) = new Uav(system)
+
+  def apply()(implicit system: ActorSystem) = super.apply(system)
+
+}