diff options
author | Jakob Odersky <jakob@driver.xyz> | 2018-09-12 13:51:36 -0700 |
---|---|---|
committer | Jakob Odersky <jakob@driver.xyz> | 2018-09-12 14:17:39 -0700 |
commit | 0c67bd769c5d4c674dd8307ecf85cd5b7815b003 (patch) | |
tree | ccf5c036ef10482519e14e83fd1c82771ed7c6a2 /src/main/scala/xyz/driver/core | |
parent | ed4fe6231bcefd7c0297f385f07a7e1bbcdd1166 (diff) | |
download | driver-core-0c67bd769c5d4c674dd8307ecf85cd5b7815b003.tar.gz driver-core-0c67bd769c5d4c674dd8307ecf85cd5b7815b003.tar.bz2 driver-core-0c67bd769c5d4c674dd8307ecf85cd5b7815b003.zip |
Remove unused protoype of a reporting bus
Diffstat (limited to 'src/main/scala/xyz/driver/core')
-rw-r--r-- | src/main/scala/xyz/driver/core/messaging/ReportingBus.scala | 34 |
1 files changed, 0 insertions, 34 deletions
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) -} |