aboutsummaryrefslogtreecommitdiff
path: root/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala
diff options
context:
space:
mode:
Diffstat (limited to 'tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala')
-rw-r--r--tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala29
1 files changed, 0 insertions, 29 deletions
diff --git a/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala b/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala
deleted file mode 100644
index 691df81..0000000
--- a/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala
+++ /dev/null
@@ -1,29 +0,0 @@
-package com.softwaremill.sttp.streaming
-
-import akka.NotUsed
-import akka.actor.ActorSystem
-import akka.stream.Materializer
-import akka.stream.scaladsl.Source
-import akka.util.ByteString
-import com.softwaremill.sttp.SttpBackend
-import com.softwaremill.sttp.akkahttp.AkkaHttpBackend
-import com.softwaremill.sttp.testing.streaming.{ConvertToFuture, TestStreamingBackend}
-
-import scala.concurrent.Future
-
-class AkkaHttpStreamingTests(actorSystem: ActorSystem)(implicit materializer: Materializer)
- extends TestStreamingBackend[Future, Source[ByteString, Any]] {
-
- 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(_ + _)
-
-}