Fixed dataflow (broken when executor option added to Future)

Author: jdantonio

lib/concurrent/dataflow.rb

@@ -64,7 +64,7 @@ def dataflow(*inputs, &block)
     raise ArgumentError.new('no block given') unless block_given?
     raise ArgumentError.new('not all dependencies are IVars') unless inputs.all? { |input| input.is_a? IVar }
 
-    result = Future.new(executor: PerThreadExecutor.new) do
+    result = Future.new do
       values = inputs.map { |input| input.value }
       block.call(*values)
     end

spec/spec_helper.rb

@@ -27,6 +27,10 @@
   end
 
   config.before(:each) do
+    Concurrent.configure do |config|
+      config.global_task_pool = Concurrent::FixedThreadPool.new(5)
+      config.global_operation_pool = Concurrent::FixedThreadPool.new(5)
+    end
   end
 
   config.after(:each) do