We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f126d73 commit 7eb8986Copy full SHA for 7eb8986
core/src/main/scala/com/avsystem/commons/concurrent/TaskExtensions.scala
@@ -21,7 +21,7 @@ object TaskExtensions extends TaskExtensions {
21
* Similar to [[Task.timeoutWith]] but exception instance is created lazily (for performance)
22
*/
23
def lazyTimeout(after: FiniteDuration, msg: => String): Task[T] =
24
- task.timeoutTo(after, Task.raiseError(new TimeoutException(msg)))
+ task.timeoutTo(after, Task.defer(Task.raiseError(new TimeoutException(msg))))
25
26
/**
27
* Similar to [[Task.tapEval]], accepts simple consumer function as an argument
0 commit comments