aboutsummaryrefslogtreecommitdiff
path: root/src/test/scala/kamon/instrumentation/ScalaFuturesSupport.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/test/scala/kamon/instrumentation/ScalaFuturesSupport.scala')
-rw-r--r--src/test/scala/kamon/instrumentation/ScalaFuturesSupport.scala32
1 files changed, 0 insertions, 32 deletions
diff --git a/src/test/scala/kamon/instrumentation/ScalaFuturesSupport.scala b/src/test/scala/kamon/instrumentation/ScalaFuturesSupport.scala
deleted file mode 100644
index cc87a7c8..00000000
--- a/src/test/scala/kamon/instrumentation/ScalaFuturesSupport.scala
+++ /dev/null
@@ -1,32 +0,0 @@
-package kamon.instrumentation
-
-import scala.concurrent.{Await, Future}
-import scala.concurrent.duration.Duration
-import scala.util.{Failure, Success}
-import org.scalatest.concurrent.Futures
-import java.util.concurrent.TimeUnit
-
-trait ScalaFuturesSupport extends Futures {
- implicit def scalaFutureToFutureConcept[T](future: Future[T]): FutureConcept[T] = new FutureConcept[T] {
- def eitherValue: Option[Either[Throwable, T]] = {
- if(!future.isCompleted)
- None
- else
- future.value match {
- case None => None
- case Some(t) => t match {
- case Success(v) => Some(Right(v))
- case Failure(e) => Some(Left(e))
- }
- }
- }
-
- def isExpired: Boolean = false // Scala futures cant expire
-
- def isCanceled: Boolean = false // Scala futures cannot be cancelled
-
- override def futureValue(implicit config: PatienceConfig): T = {
- Await.result(future, Duration(config.timeout.totalNanos, TimeUnit.NANOSECONDS))
- }
- }
-}