2 files changed, 42 insertions, 0 deletions
diff --git a/akka-http-backend/src/test/scala/com/softwaremill/sttp/akkahttp/AkkaHttpClientHttpTest.scala b/akka-http-backend/src/test/scala/com/softwaremill/sttp/akkahttp/AkkaHttpClientHttpTest.scala
new file mode 100644
index 0000000..fe72794
--- /dev/null
+++ b/akka-http-backend/src/test/scala/com/softwaremill/sttp/akkahttp/AkkaHttpClientHttpTest.scala
@@ -0,0 +1,12 @@
+package com.softwaremill.sttp.akkahttp
+
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.testing.{ConvertToFuture, HttpTest}
+
+import scala.concurrent.Future
+
+class AkkaHttpClientHttpTest extends HttpTest[Future] {
+
+  override implicit val backend: SttpBackend[Future, Nothing] = AkkaHttpBackend()
+  override implicit val convertToFuture: ConvertToFuture[Future] = ConvertToFuture.future
+}
diff --git a/akka-http-backend/src/test/scala/com/softwaremill/sttp/akkahttp/AkkaHttpStreamingTest.scala b/akka-http-backend/src/test/scala/com/softwaremill/sttp/akkahttp/AkkaHttpStreamingTest.scala
new file mode 100644
index 0000000..494ecd2
--- /dev/null
+++ b/akka-http-backend/src/test/scala/com/softwaremill/sttp/akkahttp/AkkaHttpStreamingTest.scala
@@ -0,0 +1,30 @@
+package com.softwaremill.sttp.akkahttp
+
+import akka.NotUsed
+import akka.actor.ActorSystem
+import akka.stream.ActorMaterializer
+import akka.stream.scaladsl.Source
+import akka.util.ByteString
+import com.softwaremill.sttp.SttpBackend
+import com.softwaremill.sttp.testing.ConvertToFuture
+import com.softwaremill.sttp.testing.streaming.StreamingTest
+
+import scala.concurrent.Future
+
+class AkkaHttpStreamingTest extends StreamingTest[Future, Source[ByteString, Any]] {
+
+  private implicit val actorSystem: ActorSystem = ActorSystem("sttp-test")
+  private implicit val materializer: ActorMaterializer = ActorMaterializer()
+
+  override implicit val backend: SttpBackend[Future, Source[ByteString, Any]] =
+    AkkaHttpBackend.usingActorSystem(actorSystem)
+
+  override implicit val convertToFuture: ConvertToFuture[Future] =
+    ConvertToFuture.future
+
+  override def bodyProducer(body: String): Source[ByteString, NotUsed] =
+    Source.single(ByteString(body))
+
+  override def bodyConsumer(stream: Source[ByteString, Any]): Future[String] =
+    stream.map(_.utf8String).runReduce(_ + _)
+}