Skip to content

Commit c2107ec

Browse files
committed
monix-bio-blocking: reformat
1 parent e7bf476 commit c2107ec

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

commons-core/jvm/src/main/scala/com/avsystem/commons/concurrent/BlockingUtils.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,9 +39,8 @@ abstract class BlockingUtils {
3939
def asTask[T](blockingCode: => T): Task[T] =
4040
Task.eval(blockingCode).executeOn(ioScheduler, forceAsync = true)
4141

42-
def asIO[A, B](blockingCode: => Either[A, B]): IO[A, B] = IO.deferTotal {
43-
IO.fromEither(blockingCode)
44-
}.executeOn(ioScheduler, forceAsync = true)
42+
def asIO[A, B](blockingCode: => Either[A, B]): IO[A, B] =
43+
IO.deferTotal(IO.fromEither(blockingCode)).executeOn(ioScheduler, forceAsync = true)
4544

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

0 commit comments

Comments
 (0)