some minor style fixes

Author: mighe

lib/concurrent/dataflow.rb

@@ -13,7 +13,7 @@ def initialize(count, &block)
 
     def update(time, value, reason)
       if @counter.decrement == 0
-        @block.call()
+        @block.call
       end
     end
   end

lib/concurrent/future.rb

@@ -1,5 +1,6 @@
 require 'thread'
 
+require 'concurrent/obligation'
 require 'concurrent/global_thread_pool'
 require 'concurrent/safe_task_executor'
 

lib/concurrent/mvar.rb

@@ -1,3 +1,4 @@
+require 'concurrent/dereferenceable'
 require 'concurrent/event'
 
 module Concurrent

lib/concurrent/obligation.rb

@@ -11,20 +11,28 @@ module Obligation
 
     # Has the obligation been fulfilled?
     # @return [Boolean]
-    def fulfilled?() state == :fulfilled; end
+    def fulfilled?
+      state == :fulfilled
+    end
     alias_method :realized?, :fulfilled?
 
     # Has the obligation been rejected?
     # @return [Boolean]
-    def rejected?() state == :rejected; end
+    def rejected?
+      state == :rejected
+    end
 
     # Is obligation completion still pending?
     # @return [Boolean]
-    def pending?() state == :pending; end
+    def pending?
+      state == :pending
+    end
 
     # Is the obligation still unscheduled?
     # @return [Boolean]
-    def unscheduled?() state == :unscheduled; end
+    def unscheduled?
+      state == :unscheduled
+    end
 
     def completed?
       [:fulfilled, :rejected].include? state

lib/concurrent/postable.rb

@@ -1,3 +1,5 @@
+require 'concurrent/event'
+
 module Concurrent
 
   module Postable
@@ -37,20 +39,20 @@ def post(*message)
       raise ArgumentError.new('empty message') if message.empty?
       return false unless ready?
       queue.push(Package.new(message))
-      return true
+      true
     end
 
     def <<(message)
       post(*message)
-      return self
+      self
     end
 
     def post?(*message)
       raise ArgumentError.new('empty message') if message.empty?
       return nil unless ready?
       ivar = IVar.new
       queue.push(Package.new(message, ivar))
-      return ivar
+      ivar
     end
 
     def post!(seconds, *message)
@@ -77,14 +79,14 @@ def forward(receiver, *message)
       raise ArgumentError.new('empty message') if message.empty?
       return false unless ready?
       queue.push(Package.new(message, receiver))
-      return queue.length
+      queue.length
     end
 
     def ready?
       if self.respond_to?(:running?) && ! running?
-        return false
+        false
       else
-        return true
+        true
       end
     end
 

lib/concurrent/stoppable.rb

@@ -8,13 +8,13 @@ def before_stop(&block)
       raise ArgumentError.new('no block given') unless block_given?
       raise Runnable::LifecycleError.new('#before_stop already set') if @before_stop_proc
       @before_stop_proc = block
-      return self
+      self
     end
 
     protected
 
     def before_stop_proc
-      return @before_stop_proc
+      @before_stop_proc
     end
   end
 end