# File lib/celluloid/condition.rb, line 15 def <<(message) @mailbox << message end
# File lib/celluloid/condition.rb, line 19 def wait begin message = @mailbox.receive(@timeout) do |msg| msg.is_a?(SignalConditionRequest) && msg.task == Thread.current end rescue TimeoutError raise ConditionError, "timeout after #{@timeout.inspect} seconds" end until message message.value end
Generated with the Darkfish Rdoc Generator 2.