1 files changed, 26 insertions, 0 deletions
diff --git a/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixStreamingTest.scala b/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixStreamingTest.scala
new file mode 100644
index 0000000..34c15ff
--- /dev/null
+++ b/async-http-client-backend/monix/src/test/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixStreamingTest.scala
@@ -0,0 +1,26 @@
+package com.softwaremill.sttp.asynchttpclient.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 monix.eval.Task
+import monix.reactive.Observable
+
+class AsyncHttpClientMonixStreamingTest extends StreamingTest[Task, Observable[ByteBuffer]] {
+
+  override val testStreamingBackend: TestStreamingBackend[Task, Observable[ByteBuffer]] =
+    new AsyncHttpClientMonixTestStreamingBackend
+}
+
+class AsyncHttpClientMonixTestStreamingBackend 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]] =
+    AsyncHttpClientMonixBackend()
+}