about summary refs log tree commit homepage
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2013-12-27 08:08:49 +0000
committerEric Wong <normalperson@yhbt.net>2013-12-27 08:08:49 +0000
commit010e2862de13cdd1767e7b41f2e9045d6fc413ac (patch)
treecec3d234d0637cd215ab898fdd72811d9cd9af24
parentf5d04d3986b82dc1b3503dada145f6a0897ce69d (diff)
downloaddtas-010e2862de13cdd1767e7b41f2e9045d6fc413ac.tar.gz
We do not need a begin block here, callers will deal with it.
-rw-r--r--lib/dtas/unix_server.rb20
1 files changed, 9 insertions, 11 deletions
diff --git a/lib/dtas/unix_server.rb b/lib/dtas/unix_server.rb
index 21261d3..3931239 100644
--- a/lib/dtas/unix_server.rb
+++ b/lib/dtas/unix_server.rb
@@ -93,17 +93,15 @@ class DTAS::UNIXServer # :nodoc:
   end
 
   def run_once
-    begin
-      # give IO.select one-shot behavior, snapshot and replace the watchlist
-      r = IO.select(@readers.keys, @writers.keys) or return
-      r[1].each do |io|
-        @writers.delete(io)
-        wait_ctl(io, io.writable_iter)
-      end
-      r[0].each do |io|
-        @readers.delete(io)
-        wait_ctl(io, io.readable_iter { |_io, msg| yield(_io, msg) })
-      end
+    # give IO.select one-shot behavior, snapshot and replace the watchlist
+    r = IO.select(@readers.keys, @writers.keys) or return
+    r[1].each do |io|
+      @writers.delete(io)
+      wait_ctl(io, io.writable_iter)
+    end
+    r[0].each do |io|
+      @readers.delete(io)
+      wait_ctl(io, io.readable_iter { |_io, msg| yield(_io, msg) })
     end
   end
 end