lib/evt/backends/bundled.rb
# Collect closed streams in readables and writables
Collect closed streams in readables and writables
Collect closed streams in readables and writables
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
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
Collect closed streams in readables and writables
Collect closed streams in readables and writables
force
<not_specific>