Fix: requiring concur makes Future available in the namespace

Author: lbarasti

examples/event_batching.cr

@@ -1,5 +1,4 @@
 require "../src/concur"
-include Concur
 
 record KeyboardEvent, id : Int32, key : Char
 record MouseEvent, id : Int32, pos : {Int32, Int32}

examples/parallel_processing.cr

@@ -13,6 +13,6 @@ pp Concur.source(Random.new) { |gen| {gen, {gen.rand, gen.rand}} }
   .select { |estimates|
     estimates.all? { |(i, e)|
       (e - Math::PI).abs / Math::PI < 1e-5
-    } 
+    }
   }.flat_map { |estimates| estimates.map(&.first) }
   .take 1

examples/shard.lock

@@ -8,15 +8,11 @@ shards:
     git: https://github.com/maiha/crt.cr.git
     version: 0.4.0
 
-  dataclass:
-    git: https://github.com/lbarasti/dataclass.git
-    version: 1.1.1
-
   rate_limiter:
     git: https://github.com/lbarasti/rate_limiter.git
     version: 1.0.1
 
   tablo:
     git: https://github.com/hutou/tablo.git
-    version: 0.9.5
+    version: 0.10.1
 

examples/shard.yml

@@ -4,9 +4,7 @@ version: 0.1.0
 authors:
   - lbarasti <[email protected]>
 
-dependencies: 
-  dataclass:
-    github: lbarasti/dataclass
+dependencies:
   agent:
     github: lbarasti/agent
   rate_limiter:

examples/url_checker.cr

@@ -1,13 +1,12 @@
 require "yaml"
 require "http/client"
 require "../src/concur"
-require "dataclass"
 require "agent"
 require "crt"
 require "tablo"
 extend Concur
 
-dataclass StatsCount{success : Hash(String, Int32), failure : Hash(String, Int32)}
+record StatsCount, success : Hash(String, Int32), failure : Hash(String, Int32)
 
 class Stats
   @success : Agent(Hash(String, Int32))

examples/using_futures.cr

@@ -0,0 +1,9 @@
+require "../src/concur"
+
+n = Future.new { 42 }
+  .map { |v| v // 2 }
+  .await!
+
+pp n
+
+raise Exception.new("Something went wrong") unless n == 21

shard.yml

@@ -1,5 +1,5 @@
 name: concur
-version: 1.0.1
+version: 1.0.2
 
 authors:
   - lbarasti <[email protected]>

spec/future_spec.cr

@@ -47,7 +47,7 @@ describe Future do
   it "can be awaited on with timeout" do
     f = Future.new { sleep 0.6; 42 }
     f.await(0.2.seconds)
-      .should be_a Concur::Timeout
+      .should be_a Future::Timeout
     f.await
       .should eq 42
     f.await(0.1.seconds)
@@ -56,7 +56,7 @@ describe Future do
 
   it "can be awaited on with timeout and raise on exception" do
     f = Future.new { sleep 0.4; raise CustomError.new("error"); 42 }
-    expect_raises(Concur::Timeout) {
+    expect_raises(Future::Timeout) {
       f.await!(0.2.seconds)
     }
     expect_raises(CustomError) {
@@ -124,11 +124,11 @@ describe Future do
       results << ex.as(CustomError)
       raise Exception.new("runtime exception")
     }.on_error { |ex|
-      results << Timeout.new
+      results << Future::Timeout.new
     }.await.should be_a CustomError
 
     results.first.should be_a CustomError
-    results.last.should be_a Timeout
+    results.last.should be_a Future::Timeout
   end
 
   it "will not run #on_error callbacks if the future succeeds" do
@@ -172,7 +172,7 @@ end
     g = f.select { |x| x % 2 == 1 }
     h = f.select { |x| x % 2 == 0 }
     g.await.should eq 5
-    h.await.should be_a Concur::EmptyError
+    h.await.should be_a Future::EmptyError
   end
 
   it "supports combining two futures with #flat_map" do

spec/readme_spec.cr

@@ -10,7 +10,7 @@ describe "Future example" do
     f.map { |v| v.downcase }
       .select { |v| v.size < 3 }
       .recover { |ex| ex.message || ex.class.to_s }
-      .await.should eq "Concur::EmptyError"
+      .await.should eq "Future::EmptyError"
   end
 
   it "showcases #zip and #flat_map" do