Skip to content

Commit a579897

Browse files
author
Roman Janusz
committed
added executeAsync before Monix Task's runSyncUnsafe to force proper thread pool
1 parent 11afb42 commit a579897

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ abstract class BlockingUtils {
5555
runAndAwait(task, FiniteDuration(timeout, unit))
5656

5757
def runAndAwait[T](task: Task[T], timeout: Duration): T =
58-
task.runSyncUnsafe(timeout)
58+
task.executeAsync.runSyncUnsafe(timeout)
5959

6060
// overloading instead of using default value so that it's usable from Java
6161
def toIterator[T](observable: Observable[T]): CloseableIterator[T] =

0 commit comments

Comments
 (0)