implementations/monix/src/test/scala/com/softwaremill/sttp/impl/monix/package.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

package com.softwaremill.sttp.impl

import scala.concurrent.Future

import _root_.monix.eval.Task
import com.softwaremill.sttp.testing.streaming.ConvertToFuture

package object monix {

  val convertMonixTaskToFuture: ConvertToFuture[Task] = new ConvertToFuture[Task] {
    import _root_.monix.execution.Scheduler.Implicits.global

    override def toFuture[T](value: Task[T]): Future[T] = value.runAsync
  }
}