Implemented more Agent specs.

Author: jdantonio

spec/concurrent/agent_spec.rb

@@ -33,7 +33,7 @@ def dereferenceable_observable(opts = {})
       end
 
       def execute_dereferenceable(subject)
-        subject << proc { 'value' }
+        subject.post{|value| 10 }
         sleep(0.1)
       end
 
@@ -42,6 +42,8 @@ def execute_dereferenceable(subject)
 
     context '#initialize' do
 
+      let(:executor) { ImmediateExecutor.new }
+
       it 'sets the value to the given initial state' do
         Agent.new(10).value.should eq 10
       end
@@ -54,13 +56,29 @@ def execute_dereferenceable(subject)
         Agent.new(0).timeout.should eq Agent::TIMEOUT
       end
 
-      it 'uses the executor given with the :executor option'
+      it 'uses the executor given with the :executor option' do
+        executor.should_receive(:post).with(any_args).and_return(0)
+        agent = Agent.new(0, executor: executor)
+        agent.post{|value| 0 }
+      end
 
-      it 'uses the global operation pool when :operation is true'
+      it 'uses the global operation pool when :operation is true' do
+        Concurrent.configuration.should_receive(:global_operation_pool).and_return(executor)
+        agent = Agent.new(0, operation: true)
+        agent.post{|value| 0 }
+      end
 
-      it 'uses the global task pool when :task is true'
+      it 'uses the global task pool when :task is true' do
+        Concurrent.configuration.should_receive(:global_task_pool).and_return(executor)
+        agent = Agent.new(0, task: true)
+        agent.post{|value| 0 }
+      end
 
-      it 'uses the global task pool by default'
+      it 'uses the global task pool by default' do
+        Concurrent.configuration.should_receive(:global_task_pool).and_return(executor)
+        agent = Agent.new(0)
+        agent.post{|value| 0 }
+      end
     end
 
     context '#rescue' do

spec/concurrent/dereferenceable_shared.rb

@@ -127,8 +127,6 @@
 
   it 'supports dereference flags with observers' do
     if dereferenceable_subject(0).respond_to?(:add_observer)
-      pending('intermittently failing')
-      # Concurrent::Agent behavior it should behave like dereferenceable supports dereference flags with observers
 
       result = 'result'
       result.should_receive(:dup).and_return(result)