Merge pull request #183 from JuliaGizmos/sd/07

fix remaining depwarns - actually drop 0.6

src/Reactive.jl

@@ -1,5 +1,3 @@
-__precompile__()
-
 module Reactive
 
 include("core.jl")

src/core.jl

@@ -27,11 +27,6 @@ const edges = Vector{Int}[] #parents to children, useful for plotting graphs
 
 const node_count = Dict{String, Int}() #counts of different signals for naming
 
-if VERSION < v"0.7.0-alpha.2"
-    const wait07 = wait
-else
-    const wait07 = fetch
-end
 
 if !debug_memory
     mutable struct Signal{T}
@@ -293,7 +288,7 @@ function stop()
     # it seems to take a long time until the runner_task is actually finished
     # which can be enough to run into maybe_restart_queue with !isdone(runner_task)
     # see #144
-    wait07(runner_task[])
+    fetch(runner_task[])
 end
 
 """
@@ -368,7 +363,7 @@ function run_push(pushnode::Signal, val, onerror, dont_remove_dead = false)
         end
     catch err
         if isa(err, InterruptException)
-            info("Reactive event loop was inturrupted.")
+            @info("Reactive event loop was inturrupted.")
             rethrow()
         else
             bt = catch_backtrace()
@@ -418,14 +413,14 @@ function maybe_restart_queue()
             # will happen if `add_action!` is called while processing a push!
             prev_runner = current_task()
             @async begin
-                # new runner should wait07 for current runner to process the
+                # new runner should fetch for current runner to process the
                 # break_loop (null) message
-                wait07(prev_runner)
+                fetch(prev_runner)
                 runner_task[] = current_task()
                 run()
             end
         else
-            wait07(runner_task[])
+            fetch(runner_task[])
             runner_task[] = @async run()
         end
     end

test/queue_runner.jl

@@ -16,7 +16,7 @@ import Reactive: runner_task
         end
         function test_queue(expected_bcount, orig_runner)
             push!(a, 3)
-            wait07(Reactive.runner_task[])
+            fetch(Reactive.runner_task[])
             @test (queue_size()) == (0)
             @test (orig_runner) != (Reactive.runner_task[]) # we should have a new queue runner)
             @test (bcount) == (expected_bcount)
@@ -43,7 +43,7 @@ import Reactive: runner_task
         end
         function test_queue(expected_bcount, orig_runner)
             push!(a, 3)
-            wait07(Reactive.runner_task[])
+            fetch(Reactive.runner_task[])
             @test (queue_size()) == (0)
             @test (orig_runner) != Reactive.runner_task[] # we should have a new queue runner)
             @test (bcount) == (expected_bcount)
@@ -68,7 +68,7 @@ import Reactive: runner_task
         function test_queue(expected_bcount, orig_runner)
             push!(a, 3)
             push!(a, 4)
-            wait07(Reactive.runner_task[])
+            fetch(Reactive.runner_task[])
             @test (queue_size()) == (0)
             @test (orig_runner) != (Reactive.runner_task[]) # we should have a new queue runner)
             @test (bcount) == (expected_bcount*2)
@@ -82,5 +82,5 @@ end
 
 if !istaskdone(Reactive.runner_task[])
     Reactive.stop()
-    wait07(Reactive.runner_task[])
+    fetch(Reactive.runner_task[])
 end

test/runtests.jl

@@ -1,14 +1,7 @@
 using Reactive
-if VERSION < v"0.7.0-DEV.2005"
-    using Base.Test
-else
-    using Test
-end
+using Test
 # Stop the runner task
 
-using Reactive: wait07
-
-
 @testset "Queue runner" begin
     @test (istaskdone(Reactive.runner_task[])) == (false)
     Reactive.stop()

test/time.jl

@@ -10,7 +10,7 @@
         push!(b, true)
 
         step() # processing the push to b will start the fpswhen's timer
-        # then we wait07 for two pushes from the timer, which should take ~ 1sec
+        # then we fetch for two pushes from the timer, which should take ~ 1sec
         dt = @elapsed Reactive.run(2)
         push!(b, false)
         Reactive.run(1) # setting b to false should stop the timer