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 | 7 |
1 files changed, 4 insertions, 3 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 index d8fbb82..691df81 100644 --- a/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala +++ b/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala @@ -5,8 +5,9 @@ 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.{ForceWrappedValue, SttpBackend} +import com.softwaremill.sttp.testing.streaming.{ConvertToFuture, TestStreamingBackend} import scala.concurrent.Future @@ -16,8 +17,8 @@ class AkkaHttpStreamingTests(actorSystem: ActorSystem)(implicit materializer: Ma override implicit val backend: SttpBackend[Future, Source[ByteString, Any]] = AkkaHttpBackend.usingActorSystem(actorSystem) - override implicit val forceResponse: ForceWrappedValue[Future] = - ForceWrappedValue.future + override implicit val convertToFuture: ConvertToFuture[Future] = + ConvertToFuture.future override def bodyProducer(body: String): Source[ByteString, NotUsed] = Source.single(ByteString(body)) |