1 files changed, 5 insertions, 7 deletions
diff --git a/lib/rainbows/event_machine/response_chunk_pipe.rb b/lib/rainbows/event_machine/response_chunk_pipe.rb
index af9393a..be98086 100644
--- a/lib/rainbows/event_machine/response_chunk_pipe.rb
+++ b/lib/rainbows/event_machine/response_chunk_pipe.rb
@@ -9,17 +9,15 @@ module Rainbows::EventMachine::ResponseChunkPipe
    end
  
    def notify_readable
-    begin
-      data = @io.read_nonblock(16384, RBUF)
+    case data = Kgio.tryread(@io, 16384, RBUF)
+    when String
        @client.write("#{data.size.to_s(16)}\r\n")
        @client.write(data)
        @client.write("\r\n")
-    rescue Errno::EINTR
-    rescue Errno::EAGAIN
-      return
-    rescue EOFError
-      detach
+    when :wait_readable
        return
+    when nil
+      return detach
      end while true
    end
  end