diff --git a/src/rxpkg/schedulers.nim b/src/rxpkg/schedulers.nim index d223192..5ca2992 100644 --- a/src/rxpkg/schedulers.nim +++ b/src/rxpkg/schedulers.nim @@ -20,4 +20,4 @@ proc immediateScheduler*(): Scheduler = sleep(t.millis) p() result.now = proc(): Time = - epochTime().fromSeconds() \ No newline at end of file + getTime() \ No newline at end of file diff --git a/src/rxpkg/sharedqueue.nim b/src/rxpkg/sharedqueue.nim index 577683c..7f06f0b 100644 --- a/src/rxpkg/sharedqueue.nim +++ b/src/rxpkg/sharedqueue.nim @@ -41,7 +41,6 @@ when isMainModule: x.atomicSend(2) x.atomicSend(3) - spawn: - localEcho(x) + spawn localEcho(x) sync() \ No newline at end of file