From 0c67bd769c5d4c674dd8307ecf85cd5b7815b003 Mon Sep 17 00:00:00 2001
From: Jakob Odersky <jakob@driver.xyz>
Date: Wed, 12 Sep 2018 13:51:36 -0700
Subject: Remove unused protoype of a reporting bus

---
 .../xyz/driver/core/messaging/ReportingBus.scala   | 34 ----------------------
 1 file changed, 34 deletions(-)
 delete mode 100644 src/main/scala/xyz/driver/core/messaging/ReportingBus.scala

diff --git a/src/main/scala/xyz/driver/core/messaging/ReportingBus.scala b/src/main/scala/xyz/driver/core/messaging/ReportingBus.scala
deleted file mode 100644
index 74038e4..0000000
--- a/src/main/scala/xyz/driver/core/messaging/ReportingBus.scala
+++ /dev/null
@@ -1,34 +0,0 @@
-package xyz.driver.core.messaging
-
-import xyz.driver.core.reporting.{Reporter, SpanContext}
-
-import scala.concurrent.Future
-import scala.language.higherKinds
-
-trait ReportingBus extends Bus {
-
-  def reporter: Reporter
-
-  trait TracedMessage[A] extends BasicMessage[A] { self: Message[A] =>
-    def spanContext: SpanContext
-  }
-
-  type Message[A] <: TracedMessage[A]
-
-  abstract override def publishMessages[A](topic: Topic[A], messages: Seq[A]): Future[Unit] = {
-    super.publishMessages(topic, messages)
-  }
-
-  abstract override def fetchMessages[A](
-      topic: Topic[A],
-      config: SubscriptionConfig,
-      maxMessages: Int): Future[Seq[Message[A]]] = {
-    super.fetchMessages(topic, config, maxMessages)
-  }
-
-}
-
-trait Topic2
-trait Bus2 {
-  def publishMessage[A](topic: Topic2, message: A)
-}
-- 
cgit v1.2.3