1 files changed, 25 insertions, 0 deletions
diff --git a/lib/rainbows/event_machine/response_chunk_pipe.rb b/lib/rainbows/event_machine/response_chunk_pipe.rb
new file mode 100644
index 0000000..ee8d260
--- /dev/null
+++ b/lib/rainbows/event_machine/response_chunk_pipe.rb
@@ -0,0 +1,25 @@
+# -*- encoding: binary -*-
+# :enddoc:
+module Rainbows::EventMachine::ResponseChunkPipe
+  include Rainbows::EventMachine::ResponsePipe
+
+  def unbind
+    @client.write("0\r\n\r\n")
+    super
+  end
+
+  def notify_readable
+    begin
+      data = @io.read_nonblock(16384, BUF)
+      @client.write(sprintf("%x\r\n", data.size))
+      @client.write(data)
+      @client.write("\r\n")
+    rescue Errno::EINTR
+    rescue Errno::EAGAIN
+      return
+    rescue EOFError
+      detach
+      return
+    end while true
+  end
+end