aboutsummaryrefslogtreecommitdiff
path: root/okhttp-backend
diff options
context:
space:
mode:
authorSam Guymer <sam@guymer.me>2018-05-20 21:02:37 +1000
committerSam Guymer <sam@guymer.me>2018-05-20 21:02:37 +1000
commitbcb94e252a96c78b1db29aebe47b18bfd337e764 (patch)
tree7462765d4dfcb2eda9a21591aba1bcfc51352b9f /okhttp-backend
parent92e10991df0d168d1972d4618fcc7e02e2e0a0fa (diff)
downloadsttp-bcb94e252a96c78b1db29aebe47b18bfd337e764.tar.gz
sttp-bcb94e252a96c78b1db29aebe47b18bfd337e764.tar.bz2
sttp-bcb94e252a96c78b1db29aebe47b18bfd337e764.zip
Code review updates
Remove tests sub project, all tests are now in core. Remove TestStreamingBackend, StreamingTest now has the required abstract methods.
Diffstat (limited to 'okhttp-backend')
-rw-r--r--okhttp-backend/monix/src/test/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixStreamingTest.scala19
1 files changed, 3 insertions, 16 deletions
diff --git a/okhttp-backend/monix/src/test/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixStreamingTest.scala b/okhttp-backend/monix/src/test/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixStreamingTest.scala
index af9ea9c..dd08214 100644
--- a/okhttp-backend/monix/src/test/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixStreamingTest.scala
+++ b/okhttp-backend/monix/src/test/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixStreamingTest.scala
@@ -3,24 +3,11 @@ package com.softwaremill.sttp.okhttp.monix
import java.nio.ByteBuffer
import com.softwaremill.sttp.SttpBackend
-import com.softwaremill.sttp.impl.monix.MonixTestStreamingBackend
-import com.softwaremill.sttp.testing.streaming.{StreamingTest, TestStreamingBackend}
+import com.softwaremill.sttp.impl.monix.MonixStreamingTest
import monix.eval.Task
import monix.reactive.Observable
-class OkHttpMonixStreamingTest extends StreamingTest[Task, Observable[ByteBuffer]] {
+class OkHttpMonixStreamingTest extends MonixStreamingTest {
- override val testStreamingBackend: TestStreamingBackend[Task, Observable[ByteBuffer]] =
- new OkHttpMonixTestStreamingBackend
-}
-
-class OkHttpMonixTestStreamingBackend extends MonixTestStreamingBackend[ByteBuffer] {
-
- import monix.execution.Scheduler.Implicits.global
-
- override def toByteArray(v: ByteBuffer): Array[Byte] = v.array()
- override def fromByteArray(v: Array[Byte]): ByteBuffer = ByteBuffer.wrap(v)
-
- override implicit val backend: SttpBackend[Task, Observable[ByteBuffer]] =
- OkHttpMonixBackend()
+ override implicit val backend: SttpBackend[Task, Observable[ByteBuffer]] = OkHttpMonixBackend()
}