Method: Evt::Bundled#collect

Defined in:
lib/evt/backends/bundled.rb

#collect(force = false) ⇒ Object

Collect closed streams in readables and writables



154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
 
# File 'lib/evt/backends/bundled.rb', line 154

def collect(force=false)
  if @collect_counter < COLLECT_COUNTER_MAX and !force
    @collect_counter += 1
    return
  end

  @collect_counter = 0

  @readable.keys.each do |io|
    @readable.delete(io) if io.closed?
  end
  
  @writable.keys.each do |io|
    @writable.delete(io) if io.closed?
  end

  @iovs.keys.each do |io|
    @iovs.delete(io) if io.closed?
  end
end