aboutsummaryrefslogtreecommitdiff
path: root/tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala
diff options
context:
space:
mode:
authorAdam Warski <adam@warski.org>2018-05-21 14:28:29 +0200
committerGitHub <noreply@github.com>2018-05-21 14:28:29 +0200
commitb7de29680d64c8465ba9b612cb9d903cbbc12291 (patch)
tree0d7a6b1c653393de8422e9704b9e68bb5cf7ed91 /tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala
parent588395d018c258eb74f60ad95bad706698bdf915 (diff)
parentccb1afe90e938fc2b8619dd960a1df1937f212be (diff)
downloadsttp-b7de29680d64c8465ba9b612cb9d903cbbc12291.tar.gz
sttp-b7de29680d64c8465ba9b612cb9d903cbbc12291.tar.bz2
sttp-b7de29680d64c8465ba9b612cb9d903cbbc12291.zip
Merge pull request #94 from guymers/scalajs-2HEADmaster
Move backend tests into their projects
Diffstat (limited to 'tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala')
-rw-r--r--tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala30
1 files changed, 0 insertions, 30 deletions
diff --git a/tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala b/tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala
deleted file mode 100644
index 8959ccc..0000000
--- a/tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientFs2StreamingTests.scala
+++ /dev/null
@@ -1,30 +0,0 @@
-package com.softwaremill.sttp.streaming
-
-import java.nio.ByteBuffer
-
-import cats.effect._
-import cats.instances.string._
-import com.softwaremill.sttp.SttpBackend
-import com.softwaremill.sttp.asynchttpclient.fs2.AsyncHttpClientFs2Backend
-import com.softwaremill.sttp.impl.cats.convertCatsIOToFuture
-import com.softwaremill.sttp.testing.streaming.{ConvertToFuture, TestStreamingBackend}
-import fs2.{Chunk, Stream, text}
-
-class AsyncHttpClientFs2StreamingTests extends TestStreamingBackend[IO, Stream[IO, ByteBuffer]] {
-
- override implicit val backend: SttpBackend[IO, Stream[IO, ByteBuffer]] =
- AsyncHttpClientFs2Backend[IO]()
-
- override implicit val convertToFuture: ConvertToFuture[IO] = convertCatsIOToFuture
-
- override def bodyProducer(body: String): Stream[IO, ByteBuffer] =
- Stream.emits(body.getBytes("utf-8").map(b => ByteBuffer.wrap(Array(b))))
-
- override def bodyConsumer(stream: Stream[IO, ByteBuffer]): IO[String] =
- stream
- .map(bb => Chunk.array(bb.array))
- .through(text.utf8DecodeC)
- .compile
- .foldMonoid
-
-}