diff options
author | Adam Warski <adam@warski.org> | 2018-05-18 15:52:12 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-05-18 15:52:12 +0200 |
commit | 588395d018c258eb74f60ad95bad706698bdf915 (patch) | |
tree | 2c4ee642d8efb9e6785da3fe8a7decba507329ab /implementations/scalaz/src/test/scala/com/softwaremill/sttp/impl/scalaz/package.scala | |
parent | 96ff655f906f2e3f4e9ba906c42e96506f4668b9 (diff) | |
parent | 5980017ece9be1ebf30775e5babf81e0e2f1fcd9 (diff) | |
download | sttp-588395d018c258eb74f60ad95bad706698bdf915.tar.gz sttp-588395d018c258eb74f60ad95bad706698bdf915.tar.bz2 sttp-588395d018c258eb74f60ad95bad706698bdf915.zip |
Merge pull request #93 from guymers/scalajs-1
Extract MonadAsyncError implementations
Diffstat (limited to 'implementations/scalaz/src/test/scala/com/softwaremill/sttp/impl/scalaz/package.scala')
-rw-r--r-- | implementations/scalaz/src/test/scala/com/softwaremill/sttp/impl/scalaz/package.scala | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/implementations/scalaz/src/test/scala/com/softwaremill/sttp/impl/scalaz/package.scala b/implementations/scalaz/src/test/scala/com/softwaremill/sttp/impl/scalaz/package.scala new file mode 100644 index 0000000..8ac6446 --- /dev/null +++ b/implementations/scalaz/src/test/scala/com/softwaremill/sttp/impl/scalaz/package.scala @@ -0,0 +1,25 @@ +package com.softwaremill.sttp.impl + +import com.softwaremill.sttp.testing.streaming.ConvertToFuture + +import _root_.scalaz.concurrent.Task +import _root_.scalaz.{-\/, \/-} +import scala.concurrent.{Future, Promise} +import scala.util.{Failure, Success} + +package object scalaz { + + val convertScalazTaskToFuture: ConvertToFuture[Task] = new ConvertToFuture[Task] { + // from https://github.com/Verizon/delorean + override def toFuture[T](value: Task[T]): Future[T] = { + val p = Promise[T]() + + value.unsafePerformAsync { + case \/-(a) => p.complete(Success(a)); () + case -\/(t) => p.complete(Failure(t)); () + } + + p.future + } + } +} |