diff options
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.scala | 29 |
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(_ + _) - -} |