lib/mutant/actor/receiver.rb in mutant-0.8.8 vs lib/mutant/actor/receiver.rb in mutant-0.8.9

- old
+ new

@@ -5,12 +5,10 @@ include Adamantium::Flat, Concord.new(:condition_variable, :mutex, :messages) # Receives a message, blocking # # @return [Object] - # - # @api private def call 2.times do message = try_blocking_receive return message unless message.equal?(Undefined) end @@ -24,11 +22,9 @@ # @return [Undefined] # if there is no message yet # # @return [Object] # if there is a message - # - # @api private def try_blocking_receive mutex.synchronize do if messages.empty? condition_variable.wait(mutex) Undefined