diff options
| author | Sam Guymer <sam@guymer.me> | 2018-05-17 20:07:04 +1000 |
|---|---|---|
| committer | Sam Guymer <sam@guymer.me> | 2018-05-18 22:33:21 +1000 |
| commit | 5980017ece9be1ebf30775e5babf81e0e2f1fcd9 (patch) | |
| tree | 2c4ee642d8efb9e6785da3fe8a7decba507329ab /implementations/monix/src/test/scala/com/softwaremill/sttp/impl/monix/MonixTestStreamingBackend.scala | |
| parent | 40288a1aaddfc27e141771371d69122ce222a8d0 (diff) | |
| download | sttp-5980017ece9be1ebf30775e5babf81e0e2f1fcd9.tar.gz sttp-5980017ece9be1ebf30775e5babf81e0e2f1fcd9.tar.bz2 sttp-5980017ece9be1ebf30775e5babf81e0e2f1fcd9.zip | |
Code review updates
Diffstat (limited to 'implementations/monix/src/test/scala/com/softwaremill/sttp/impl/monix/MonixTestStreamingBackend.scala')
| -rw-r--r-- | implementations/monix/src/test/scala/com/softwaremill/sttp/impl/monix/MonixTestStreamingBackend.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/implementations/monix/src/test/scala/com/softwaremill/sttp/impl/monix/MonixTestStreamingBackend.scala b/implementations/monix/src/test/scala/com/softwaremill/sttp/impl/monix/MonixTestStreamingBackend.scala index c6e44da..3f84ec3 100644 --- a/implementations/monix/src/test/scala/com/softwaremill/sttp/impl/monix/MonixTestStreamingBackend.scala +++ b/implementations/monix/src/test/scala/com/softwaremill/sttp/impl/monix/MonixTestStreamingBackend.scala @@ -2,13 +2,13 @@ package com.softwaremill.sttp.impl.monix import java.nio.ByteBuffer -import _root_.monix.eval.Task -import _root_.monix.reactive.Observable import com.softwaremill.sttp.testing.streaming.{ConvertToFuture, TestStreamingBackend} +import monix.eval.Task +import monix.reactive.Observable trait MonixTestStreamingBackend extends TestStreamingBackend[Task, Observable[ByteBuffer]] { - override implicit def convertToFuture: ConvertToFuture[Task] = com.softwaremill.sttp.impl.monix.convertToFuture + override implicit def convertToFuture: ConvertToFuture[Task] = convertMonixTaskToFuture override def bodyProducer(body: String): Observable[ByteBuffer] = Observable.fromIterable(body.getBytes("utf-8").map(b => ByteBuffer.wrap(Array(b)))) |