Skip to content

Commit

Permalink
Fixes zio#845
Browse files Browse the repository at this point in the history
  • Loading branch information
jdegoes committed May 19, 2019
1 parent f53c0cc commit 71c2628
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@ import scalaz.zio.internal.{ Scheduler => IScheduler }

import scala.scalajs.js

trait SchedulerLive extends Scheduler {
private[this] val scheduler0 = new IScheduler {
private[scheduler] object internal {
private[scheduler] val GlobalScheduler = new IScheduler {
import IScheduler.CancelToken

private[this] val ConstFalse = () => false
Expand Down Expand Up @@ -65,9 +65,11 @@ trait SchedulerLive extends Scheduler {
*/
override def shutdown(): Unit = ()
}
}

trait SchedulerLive extends Scheduler {
val scheduler: Scheduler.Service[Any] = new Scheduler.Service[Any] {
val scheduler = ZIO.succeed(scheduler0)
val scheduler = ZIO.succeed(internal.GlobalScheduler)
}
}
object SchedulerLive extends SchedulerLive
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,8 @@ import scalaz.zio.internal.{ NamedThreadFactory, Scheduler => IScheduler }
import java.util.concurrent._
import java.util.concurrent.atomic.AtomicInteger

trait SchedulerLive extends Scheduler {
private[this] val scheduler0 = new IScheduler {
private[scheduler] object internal {
private[scheduler] val GlobalScheduler = new IScheduler {
import IScheduler.CancelToken

val service = Executors.newScheduledThreadPool(1, new NamedThreadFactory("zio-timer", true))
Expand Down Expand Up @@ -63,9 +63,11 @@ trait SchedulerLive extends Scheduler {

override def shutdown(): Unit = service.shutdown()
}
}

trait SchedulerLive extends Scheduler {
val scheduler: Scheduler.Service[Any] = new Scheduler.Service[Any] {
val scheduler = ZIO.succeed(scheduler0)
val scheduler = ZIO.succeed(internal.GlobalScheduler)
}
}
object SchedulerLive extends SchedulerLive
4 changes: 2 additions & 2 deletions core/shared/src/main/scala/scalaz/zio/clock/Clock.scala
Original file line number Diff line number Diff line change
Expand Up @@ -19,10 +19,10 @@ package scalaz.zio.clock
import java.util.concurrent.TimeUnit

import scalaz.zio.duration.Duration
import scalaz.zio.scheduler.{ Scheduler, SchedulerLive }
import scalaz.zio.scheduler.SchedulerLive
import scalaz.zio.{ IO, UIO, ZIO }

trait Clock extends Scheduler with Serializable {
trait Clock extends Serializable {
val clock: Clock.Service[Any]
}

Expand Down

0 comments on commit 71c2628

Please sign in to comment.