# File lib/pr_eventmachine.rb, line 351 351: def crank_selectables 352: #$stderr.write 'R' 353: 354: readers = @selectables.values.select {|io| io.select_for_reading?} 355: writers = @selectables.values.select {|io| io.select_for_writing?} 356: 357: s = select( readers, writers, nil, @timer_quantum) 358: 359: s and s[1] and s[1].each {|w| w.eventable_write } 360: s and s[0] and s[0].each {|r| r.eventable_read } 361: 362: @selectables.delete_if {|k,io| 363: if io.close_scheduled? 364: io.close 365: true 366: end 367: } 368: end