diff options
| -rw-r--r-- | lib/rainbows/xepoll_thread_spawn/client.rb | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/lib/rainbows/xepoll_thread_spawn/client.rb b/lib/rainbows/xepoll_thread_spawn/client.rb index 8cb3d27..76b4ca2 100644 --- a/lib/rainbows/xepoll_thread_spawn/client.rb +++ b/lib/rainbows/xepoll_thread_spawn/client.rb @@ -56,7 +56,7 @@ module Rainbows::XEpollThreadSpawn::Client ot = now - ot defer = [] LOCK.synchronize do - KATO.delete_if { |client, time| time < ot and client.timeout!(defer) } + KATO.delete_if { |client, time| time < ot and defer << client } end defer.each { |io| io.closed? or io.close } end @@ -68,10 +68,6 @@ module Rainbows::XEpollThreadSpawn::Client epoll_run(buf) end - def timeout!(defer) - defer << self - end - def close super kato_delete |