diff options
Diffstat (limited to 'tests/src/test/scala/com/softwaremill/sttp/streaming')
-rw-r--r-- | tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala (renamed from tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaStreamingTests.scala) | 6 | ||||
-rw-r--r-- | tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala (renamed from tests/src/test/scala/com/softwaremill/sttp/streaming/Fs2StreamingTests.scala) | 6 | ||||
-rw-r--r-- | tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientMonixStreamingTests.scala (renamed from tests/src/test/scala/com/softwaremill/sttp/streaming/MonixAHCStreamingTests.scala) | 6 | ||||
-rw-r--r-- | tests/src/test/scala/com/softwaremill/sttp/streaming/OkHttpMonixStreamingTests.scala (renamed from tests/src/test/scala/com/softwaremill/sttp/streaming/MonixOKHStreamingTests.scala) | 6 |
4 files changed, 12 insertions, 12 deletions
diff --git a/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaStreamingTests.scala b/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala index 53fe63e..25a8d6e 100644 --- a/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaStreamingTests.scala +++ b/tests/src/test/scala/com/softwaremill/sttp/streaming/AkkaHttpStreamingTests.scala @@ -5,17 +5,17 @@ import akka.actor.ActorSystem import akka.stream.Materializer import akka.stream.scaladsl.Source import akka.util.ByteString +import com.softwaremill.sttp.akkahttp.AkkaHttpHandler import com.softwaremill.sttp.{ForceWrappedValue, SttpHandler} -import com.softwaremill.sttp.akkahttp.AkkaHttpSttpHandler import scala.concurrent.Future -class AkkaStreamingTests(actorSystem: ActorSystem)( +class AkkaHttpStreamingTests(actorSystem: ActorSystem)( implicit materializer: Materializer) extends TestStreamingHandler[Future, Source[ByteString, Any]] { override implicit val handler: SttpHandler[Future, Source[ByteString, Any]] = - AkkaHttpSttpHandler.usingActorSystem(actorSystem) + AkkaHttpHandler.usingActorSystem(actorSystem) override implicit val forceResponse: ForceWrappedValue[Future] = ForceWrappedValue.future diff --git a/tests/src/test/scala/com/softwaremill/sttp/streaming/Fs2StreamingTests.scala b/tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala index b9d249b..b55d104 100644 --- a/tests/src/test/scala/com/softwaremill/sttp/streaming/Fs2StreamingTests.scala +++ b/tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala @@ -4,15 +4,15 @@ import java.nio.ByteBuffer import cats.effect._ import cats.implicits._ -import com.softwaremill.sttp.asynchttpclient.fs2.Fs2AsyncHttpClientHandler +import com.softwaremill.sttp.asynchttpclient.fs2.AsyncHttpClientFs2Handler import com.softwaremill.sttp.{ForceWrappedValue, SttpHandler} import fs2._ -class Fs2StreamingTests +class AsyncHttpClientFs2StreamingTests extends TestStreamingHandler[IO, Stream[IO, ByteBuffer]] { override implicit val handler: SttpHandler[IO, Stream[IO, ByteBuffer]] = - Fs2AsyncHttpClientHandler[IO]() + AsyncHttpClientFs2Handler[IO]() override implicit val forceResponse: ForceWrappedValue[IO] = ForceWrappedValue.catsIo diff --git a/tests/src/test/scala/com/softwaremill/sttp/streaming/MonixAHCStreamingTests.scala b/tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientMonixStreamingTests.scala index 4a4ff96..a76aa26 100644 --- a/tests/src/test/scala/com/softwaremill/sttp/streaming/MonixAHCStreamingTests.scala +++ b/tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientMonixStreamingTests.scala @@ -3,15 +3,15 @@ package com.softwaremill.sttp.streaming import java.nio.ByteBuffer import com.softwaremill.sttp.SttpHandler -import com.softwaremill.sttp.asynchttpclient.monix.MonixAsyncHttpClientHandler +import com.softwaremill.sttp.asynchttpclient.monix.AsyncHttpClientMonixHandler import monix.eval.Task import monix.reactive.Observable -class MonixAHCStreamingTests extends MonixBaseHandler { +class AsyncHttpClientMonixStreamingTests extends MonixBaseHandler { import monix.execution.Scheduler.Implicits.global override implicit val handler: SttpHandler[Task, Observable[ByteBuffer]] = - MonixAsyncHttpClientHandler() + AsyncHttpClientMonixHandler() } diff --git a/tests/src/test/scala/com/softwaremill/sttp/streaming/MonixOKHStreamingTests.scala b/tests/src/test/scala/com/softwaremill/sttp/streaming/OkHttpMonixStreamingTests.scala index 04666be..2ea1322 100644 --- a/tests/src/test/scala/com/softwaremill/sttp/streaming/MonixOKHStreamingTests.scala +++ b/tests/src/test/scala/com/softwaremill/sttp/streaming/OkHttpMonixStreamingTests.scala @@ -3,15 +3,15 @@ package com.softwaremill.sttp.streaming import java.nio.ByteBuffer import com.softwaremill.sttp.SttpHandler -import com.softwaremill.sttp.okhttp.monix.OkHttpMonixClientHandler +import com.softwaremill.sttp.okhttp.monix.OkHttpMonixHandler import monix.eval.Task import monix.reactive.Observable -class MonixOKHStreamingTests extends MonixBaseHandler { +class OkHttpMonixStreamingTests extends MonixBaseHandler { import monix.execution.Scheduler.Implicits.global override implicit val handler: SttpHandler[Task, Observable[ByteBuffer]] = - OkHttpMonixClientHandler() + OkHttpMonixHandler() } |