4741723636

Committed 19 Apr 2023 09:30AM CUT coverage: 66.912% (-5.6%) from 72.477%

Build Type

push

Committed by Roland Tritsch

Commit Message

Even more time to shut down.

Run Details

91 of 136 relevant lines covered (66.91%)

0.65 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

60.0

/src/main/scala/org/scoverage/samples/Futures.scala

package org.scoverage.samples

import scala.concurrent.{Promise, Future, ExecutionContext}
import scala.language.implicitConversions

class Futures {

  import EitherMappableFuture._

  def insert[T](
      doc: T
  )(implicit name: String, executor: ExecutionContext): Future[Result] = {
    val promise = Promise[Result]()
    Future {
      Thread.sleep(300)
    }.onComplete { case _ =>
      promise.success(Result(true, 421))
    }
    promise.future.mapEither(meaningful)
  }

  def check(result: Result): Either[Exception, Result] = Right(result)

  def meaningful(result: Result) = {
    check(result) match {
      case Left(e)  => Left(e)
      case Right(r) => Right(r)
    }
  }
}

case class Result(
    success: Boolean = true,
    status: Int = 200,
    timestamp: Long = System.currentTimeMillis
)

case class EitherMappableFuture[A](future: Future[A]) {
  def mapEither[E <: Throwable, B](
      f: A => Either[E, B]
  )(implicit ec: ExecutionContext): Future[B] = {
    future.flatMap(f(_) match {
      case Left(e)  => Future.failed(e)
      case Right(b) => Future.successful(b)
    })
  }
}
object EitherMappableFuture {
  implicit def futureToEitherMappable[A](
      future: Future[A]
  ): EitherMappableFuture[A] = EitherMappableFuture(future)
}

1	package org.scoverage.samples
2
3	import scala.concurrent.{Promise, Future, ExecutionContext}
4	import scala.language.implicitConversions
5
6	class Futures {
7
8	import EitherMappableFuture._
9		1✔
10	def insert[T](
11	doc: T
12	)(implicit name: String, executor: ExecutionContext): Future[Result] = {	1✔
13	val promise = Promise[Result]()	×
14	Future {	×
15	Thread.sleep(300)	1✔
16	}.onComplete { case _ =>	1✔
17	promise.success(Result(true, 421))
18	}	×
19	promise.future.mapEither(meaningful)
20	}
21		×
22	def check(result: Result): Either[Exception, Result] = Right(result)
23		1✔
24	def meaningful(result: Result) = {	1✔
25	check(result) match {	×
26	case Left(e) => Left(e)	1✔
27	case Right(r) => Right(r)
28	}
29	}
30	}
31
32	case class Result(	×
33	success: Boolean = true,	×
34	status: Int = 200,	1✔
35	timestamp: Long = System.currentTimeMillis
36	)
37
38	case class EitherMappableFuture[A](future: Future[A]) {	1✔
39	def mapEither[E <: Throwable, B](
40	f: A => Either[E, B]
41	)(implicit ec: ExecutionContext): Future[B] = {	1✔
42	future.flatMap(f(_) match {	×
43	case Left(e) => Future.failed(e)	1✔
44	case Right(b) => Future.successful(b)
45	})
46	}
47	}
48	object EitherMappableFuture {	1✔
49	implicit def futureToEitherMappable[A](
50	future: Future[A]
51	): EitherMappableFuture[A] = EitherMappableFuture(future)
52	}

scoverage / sbt-scoverage-samples / 4741723636

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous