Kouhei Sutou
null+****@clear*****
Sun Mar 23 18:20:18 JST 2014
Kouhei Sutou 2014-03-23 18:20:18 +0900 (Sun, 23 Mar 2014) New Revision: 3c085cd7d62d7e76245a44627faac8081d415669 https://github.com/droonga/fluent-plugin-droonga/commit/3c085cd7d62d7e76245a44627faac8081d415669 Message: Extract as a method Modified files: lib/droonga/job_pusher.rb Modified: lib/droonga/job_pusher.rb (+11 -6) =================================================================== --- lib/droonga/job_pusher.rb 2014-03-23 18:06:30 +0900 (4f89344) +++ lib/droonga/job_pusher.rb 2014-03-23 18:20:18 +0900 (5264002) @@ -77,12 +77,8 @@ module Droonga def add_worker(worker) @workers << worker - worker.on_ready = lambda do |w| - if****@buffe*****? - @ready_workers << w - else - w.write(@buffers.shift) - end + worker.on_ready = lambda do |ready_worker| + supply_job(ready_worker) end end @@ -100,6 +96,15 @@ module Droonga end end end + + private + def supply_job(worker) + if****@buffe*****? + @ready_workers << worker + else + worker.write(@buffers.shift) + end + end end class WorkerConnection -------------- next part -------------- HTML����������������������������...ダウンロード
