Method: Channel#each

Defined in:
lib/channel.rb

#each ⇒ Object 



70
71
72
73
74
75
76
77
78
79
80
81
82
 
# File 'lib/channel.rb', line 70

def each
  return enum_for(:each) unless block_given?

  loop do
    begin
      e = recv
    rescue Channel::Closed
      return
    else
      yield e
    end
  end
end