diff options
Diffstat (limited to 'tests/src/test/scala/com/softwaremill/sttp/streaming/MonixBaseBackend.scala')
| -rw-r--r-- | tests/src/test/scala/com/softwaremill/sttp/streaming/MonixBaseBackend.scala | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/tests/src/test/scala/com/softwaremill/sttp/streaming/MonixBaseBackend.scala b/tests/src/test/scala/com/softwaremill/sttp/streaming/MonixBaseBackend.scala index 3510fbc..acd67a7 100644 --- a/tests/src/test/scala/com/softwaremill/sttp/streaming/MonixBaseBackend.scala +++ b/tests/src/test/scala/com/softwaremill/sttp/streaming/MonixBaseBackend.scala @@ -6,15 +6,13 @@ import com.softwaremill.sttp.ForceWrappedValue import monix.eval.Task import monix.reactive.Observable -trait MonixBaseBackend - extends TestStreamingBackend[Task, Observable[ByteBuffer]] { +trait MonixBaseBackend extends TestStreamingBackend[Task, Observable[ByteBuffer]] { override implicit def forceResponse: ForceWrappedValue[Task] = ForceWrappedValue.monixTask override def bodyProducer(body: String): Observable[ByteBuffer] = - Observable.fromIterable( - body.getBytes("utf-8").map(b => ByteBuffer.wrap(Array(b)))) + Observable.fromIterable(body.getBytes("utf-8").map(b => ByteBuffer.wrap(Array(b)))) override def bodyConsumer(stream: Observable[ByteBuffer]): Task[String] = stream |