Agent#await does not alter the value

Author: pitr-ch

lib/concurrent/agent.rb

@@ -152,7 +152,7 @@ def <<(block)
     # @return [Boolean] false on timeout, true otherwise
     def await(timeout = nil)
       done = Event.new
-      post { done.set }
+      post { |val| done.set; val }
       done.wait timeout
     end
 

spec/concurrent/agent_spec.rb

@@ -189,6 +189,12 @@ def trigger_observable(observable)
         fn.should be_false
       end
 
+      it 'does not alter the value' do
+        subject.post { |v| v + 1 }
+        subject.await
+        subject.value.should eq 1
+      end
+
     end
 
     context 'fulfillment' do