Skip to content

Commit c90c903

Browse files
committed
let the wrapped scheduler create InterceptRunnable when no UncaughtExceptionReporter override is present
1 parent 227c7b7 commit c90c903

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

monix-execution/shared/src/main/scala/monix/execution/schedulers/ReferenceScheduler.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -115,15 +115,15 @@ object ReferenceScheduler {
115115
private[this] val reporterRef = if (reporter eq null) s else reporter
116116

117117
override def execute(runnable: Runnable): Unit =
118-
s.execute(InterceptRunnable(runnable, reporterRef))
118+
s.execute(InterceptRunnable(runnable, reporter))
119119
override def reportFailure(t: Throwable): Unit =
120120
reporterRef.reportFailure(t)
121121
override def scheduleOnce(initialDelay: Long, unit: TimeUnit, r: Runnable): Cancelable =
122-
s.scheduleOnce(initialDelay, unit, InterceptRunnable(r, reporterRef))
122+
s.scheduleOnce(initialDelay, unit, InterceptRunnable(r, reporter))
123123
override def scheduleWithFixedDelay(initialDelay: Long, delay: Long, unit: TimeUnit, r: Runnable): Cancelable =
124-
s.scheduleWithFixedDelay(initialDelay, delay, unit, InterceptRunnable(r, reporterRef))
124+
s.scheduleWithFixedDelay(initialDelay, delay, unit, InterceptRunnable(r, reporter))
125125
override def scheduleAtFixedRate(initialDelay: Long, period: Long, unit: TimeUnit, r: Runnable): Cancelable =
126-
s.scheduleAtFixedRate(initialDelay, period, unit, InterceptRunnable(r, reporterRef))
126+
s.scheduleAtFixedRate(initialDelay, period, unit, InterceptRunnable(r, reporter))
127127
override def clockRealTime(unit: TimeUnit): Long =
128128
s.clockRealTime(unit)
129129
override def clockMonotonic(unit: TimeUnit): Long =

0 commit comments

Comments
 (0)