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