Fix: let Concur extend self

examples/parallel_processing.cr

@@ -1,15 +1,14 @@
 require "../src/concur"
-include Concur
 
 # How many iterations does it take us to get 10 consecutive
 # estimates of PI with small relative error?
 # Reference: https://en.wikipedia.org/wiki/Approximations_of_%CF%80#Summing_a_circle's_area
-pp source(Random.new) { |gen| {gen, {gen.rand, gen.rand}} }
+pp Concur.source(Random.new) { |gen| {gen, {gen.rand, gen.rand}} }
   .map(workers: 4) { |(x,y)| x**2 + y**2 }
   .scan({0, 0}) { |acc, v|
     v <= 1 ? {acc[0] + 1, acc[1]} : {acc[0], acc[1] + 1}
   }.map { |(inner, outer)| 4 * inner / (inner + outer)}
-  .zip(source(1..)) { |estimate, iteration| {iteration, estimate} }
+  .zip(Concur.source(1..)) { |estimate, iteration| {iteration, estimate} }
   .batch(10, 1.second)
   .select { |estimates|
     estimates.all? { |(i, e)|

shard.yml

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

src/concur.cr

@@ -1,6 +1,8 @@
 require "rate_limiter"
 
 module Concur
+  extend self
+
   # Returns a channel that will receive each element in the given enumerable,
   # and then close.
   def source(input : Enumerable(T), name = nil, buffer_size = 0) : Channel(T) forall T
@@ -210,7 +212,7 @@ abstract class ::Channel(T)
   ) : Channel(V) forall V
     enum_stream = map(workers: workers, name: name.try{ |s| "#{s}.map" },
       on_error: on_error, &block)
-    flatten(enum_stream, name, buffer_size)
+    Concur.flatten(enum_stream, name, buffer_size)
   end
 
   # Returns a channel that receives values from `self` transformed via *block* and based
@@ -396,7 +398,7 @@ abstract class ::Channel(T)
   def batch(size : Int32, interval : Time::Span, name = nil, buffer_size = 0) : Channel(Enumerable(T))
     Channel(Enumerable(T)).new(buffer_size).tap { |stream|
       memory = Array(T).new(size)
-      tick = every(interval) { nil }
+      tick = Concur.every(interval) { nil }
       sent = false
       spawn(name: name) do
         loop do