diff options
author | Sam Guymer <sam@guymer.me> | 2018-05-20 21:02:37 +1000 |
---|---|---|
committer | Sam Guymer <sam@guymer.me> | 2018-05-20 21:02:37 +1000 |
commit | bcb94e252a96c78b1db29aebe47b18bfd337e764 (patch) | |
tree | 7462765d4dfcb2eda9a21591aba1bcfc51352b9f /okhttp-backend | |
parent | 92e10991df0d168d1972d4618fcc7e02e2e0a0fa (diff) | |
download | sttp-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.scala | 19 |
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() } |