aboutsummaryrefslogtreecommitdiff
path: root/tests/src/test/scala/com/softwaremill/sttp/streaming
diff options
context:
space:
mode:
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()
}