7 files changed, 113 insertions, 0 deletions
diff --git a/async-http-client-backend/cats/src/test/scala/com/softwaremill/sttp/asynchttpclient/cats/AsyncHttpClientCatsHttpTest.scala b/async-http-client-backend/cats/src/test/scala/com/softwaremill/sttp/asynchttpclient/cats/AsyncHttpClientCatsHttpTest.scala
new file mode 100644
index 0000000..5136914
--- /dev/null
+++ b/async-http-client-backend/cats/src/test/scala/com/softwaremill/sttp/asynchttpclient/cats/AsyncHttpClientCatsHttpTest.scala
@@ -0,0 +1,12 @@
+package com.softwaremill.sttp.asynchttpclient.cats
+
+import cats.effect.IO
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.impl.cats.convertCatsIOToFuture
+import com.softwaremill.sttp.testing.{ConvertToFuture, HttpTest}
+
+class AsyncHttpClientCatsHttpTest extends HttpTest[IO] {
+
+  override implicit val backend: SttpBackend[IO, Nothing] = AsyncHttpClientCatsBackend()
+  override implicit val convertToFuture: ConvertToFuture[IO] = convertCatsIOToFuture
+}
diff --git a/async-http-client-backend/fs2/src/test/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2HttpStreamingTest.scala b/async-http-client-backend/fs2/src/test/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2HttpStreamingTest.scala
new file mode 100644
index 0000000..56bb18b
--- /dev/null
+++ b/async-http-client-backend/fs2/src/test/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2HttpStreamingTest.scala
@@ -0,0 +1,33 @@
+package com.softwaremill.sttp.asynchttpclient.fs2
+
+import java.nio.ByteBuffer
+
+import cats.effect.IO
+import cats.instances.string._
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.testing.streaming.StreamingTest
+import com.softwaremill.sttp.testing.ConvertToFuture
+import fs2.{Chunk, Stream, text}
+import scala.concurrent.Future
+
+class AsyncHttpClientFs2HttpStreamingTest extends StreamingTest[IO, Stream[IO, ByteBuffer]] {
+
+  override implicit val backend: SttpBackend[IO, Stream[IO, ByteBuffer]] = AsyncHttpClientFs2Backend[IO]()
+
+  override implicit val convertToFuture: ConvertToFuture[IO] =
+    new ConvertToFuture[IO] {
+      override def toFuture[T](value: IO[T]): Future[T] =
+        value.unsafeToFuture()
+    }
+
+  override def bodyProducer(body: String): Stream[IO, ByteBuffer] =
+    Stream.emits(body.getBytes("utf-8")).map(b => ByteBuffer.wrap(Array(b)))
+
+  override def bodyConsumer(stream: Stream[IO, ByteBuffer]): IO[String] =
+    stream
+      .map(bb => Chunk.array(bb.array))
+      .through(text.utf8DecodeC)
+      .compile
+      .foldMonoid
+
+}
diff --git a/async-http-client-backend/fs2/src/test/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2HttpTest.scala b/async-http-client-backend/fs2/src/test/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2HttpTest.scala
new file mode 100644
index 0000000..7772c23
--- /dev/null
+++ b/async-http-client-backend/fs2/src/test/scala/com/softwaremill/sttp/asynchttpclient/fs2/AsyncHttpClientFs2HttpTest.scala
@@ -0,0 +1,15 @@
+package com.softwaremill.sttp.asynchttpclient.fs2
+
+import cats.effect.IO
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.testing.{ConvertToFuture, HttpTest}
+
+import scala.concurrent.Future
+
+class AsyncHttpClientFs2HttpTest extends HttpTest[IO] {
+
+  override implicit val backend: SttpBackend[IO, Nothing] = AsyncHttpClientFs2Backend()
+  override implicit val convertToFuture: ConvertToFuture[IO] = new ConvertToFuture[IO] {
+    override def toFuture[T](value: IO[T]): Future[T] = value.unsafeToFuture()
+  }
+}
diff --git a/async-http-client-backend/future/src/test/scala/com/softwaremill/sttp/asynchttpclient/future/AsyncHttpClientFutureHttpTest.scala b/async-http-client-backend/future/src/test/scala/com/softwaremill/sttp/asynchttpclient/future/AsyncHttpClientFutureHttpTest.scala
new file mode 100644
index 0000000..58d8aa8
--- /dev/null
+++ b/async-http-client-backend/future/src/test/scala/com/softwaremill/sttp/asynchttpclient/future/AsyncHttpClientFutureHttpTest.scala
@@ -0,0 +1,12 @@
+package com.softwaremill.sttp.asynchttpclient.future
+
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.testing.{ConvertToFuture, HttpTest}
+
+import scala.concurrent.Future
+
+class AsyncHttpClientFutureHttpTest extends HttpTest[Future] {
+
+  override implicit val backend: SttpBackend[Future, Nothing] = AsyncHttpClientFutureBackend()
+  override implicit val convertToFuture: ConvertToFuture[Future] = ConvertToFuture.future
+}
diff --git a/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixHttpTest.scala b/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixHttpTest.scala
new file mode 100644
index 0000000..a08e738
--- /dev/null
+++ b/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixHttpTest.scala
@@ -0,0 +1,15 @@
+package com.softwaremill.sttp.asynchttpclient.monix
+
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.impl.monix.convertMonixTaskToFuture
+import com.softwaremill.sttp.testing.{ConvertToFuture, HttpTest}
+import monix.eval.Task
+
+class AsyncHttpClientMonixHttpTest extends HttpTest[Task] {
+
+  import monix.execution.Scheduler.Implicits.global
+
+  override implicit val backend: SttpBackend[Task, Nothing] = AsyncHttpClientMonixBackend()
+  override implicit val convertToFuture: ConvertToFuture[Task] = convertMonixTaskToFuture
+
+}
diff --git a/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixStreamingTest.scala b/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixStreamingTest.scala
new file mode 100644
index 0000000..8e93074
--- /dev/null
+++ b/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixStreamingTest.scala
@@ -0,0 +1,13 @@
+package com.softwaremill.sttp.asynchttpclient.monix
+
+import java.nio.ByteBuffer
+
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.impl.monix.MonixStreamingTest
+import monix.eval.Task
+import monix.reactive.Observable
+
+class AsyncHttpClientMonixStreamingTest extends MonixStreamingTest {
+
+  override implicit val backend: SttpBackend[Task, Observable[ByteBuffer]] = AsyncHttpClientMonixBackend()
+}
diff --git a/async-http-client-backend/scalaz/src/test/scala/com/softwaremill/sttp/asynchttpclient/scalaz/AsyncHttpClientScalazHttpTest.scala b/async-http-client-backend/scalaz/src/test/scala/com/softwaremill/sttp/asynchttpclient/scalaz/AsyncHttpClientScalazHttpTest.scala
new file mode 100644
index 0000000..67acc09
--- /dev/null
+++ b/async-http-client-backend/scalaz/src/test/scala/com/softwaremill/sttp/asynchttpclient/scalaz/AsyncHttpClientScalazHttpTest.scala
@@ -0,0 +1,13 @@
+package com.softwaremill.sttp.asynchttpclient.scalaz
+
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.impl.scalaz.convertScalazTaskToFuture
+import com.softwaremill.sttp.testing.{ConvertToFuture, HttpTest}
+
+import scalaz.concurrent.Task
+
+class AsyncHttpClientScalazHttpTest extends HttpTest[Task] {
+
+  override implicit val backend: SttpBackend[Task, Nothing] = AsyncHttpClientScalazBackend()
+  override implicit val convertToFuture: ConvertToFuture[Task] = convertScalazTaskToFuture
+}