Skip to content

Commit

Permalink
Merge pull request #478 from AVSystem/monix-bio
Browse files Browse the repository at this point in the history
Remove BlockingUtils#asIO & monix-bio optional dependency
  • Loading branch information
ddworak authored Aug 14, 2023
2 parents f6e5dfd + 3edc54b commit 9c781dd
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import com.avsystem.commons.collection.CloseableIterator
import monix.eval.Task
import monix.execution.Scheduler
import monix.reactive.Observable
import monix.bio.IO

import scala.concurrent.Await
import scala.concurrent.duration._
Expand Down Expand Up @@ -39,9 +38,6 @@ abstract class BlockingUtils {
def asTask[T](blockingCode: => T): Task[T] =
Task.eval(blockingCode).executeOn(ioScheduler, forceAsync = true)

def asIO[A, B](blockingCode: => Either[A, B]): IO[A, B] =
IO.deferTotal(IO.fromEither(blockingCode)).executeOn(ioScheduler, forceAsync = true)

def await[T](future: Future[T]): T =
await(future, defaultTimeout)

Expand Down
2 changes: 0 additions & 2 deletions project/Commons.scala
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,6 @@ object Commons extends ProjectGroup("commons") {
val scalaLoggingVersion = "3.9.5"
val akkaVersion = "2.6.19"
val monixVersion = "3.4.1"
val monixBioVersion = "1.2.0"
val circeVersion = "0.14.5" // benchmark only
val upickleVersion = "3.1.2" // benchmark only
val scalajsBenchmarkVersion = "0.10.0"
Expand Down Expand Up @@ -287,7 +286,6 @@ object Commons extends ProjectGroup("commons") {
"com.google.code.findbugs" % "jsr305" % jsr305Version % Optional,
"com.google.guava" % "guava" % guavaVersion % Optional,
"io.monix" %% "monix" % monixVersion % Optional,
"io.monix" %% "monix-bio" % monixBioVersion % Optional,
),
)

Expand Down

0 comments on commit 9c781dd

Please sign in to comment.