event_machine: cleanup response_pipe
[rainbows.git] / lib / rainbows / coolio / deferred_chunk_response.rb
blob6ced2e65aff33f8e8b88aeb05384df7440474072
1 # -*- encoding: binary -*-
2 # :enddoc:
4 # this is class is specific to Coolio for proxying IO-derived objects
5 class Rainbows::Coolio::DeferredChunkResponse <
6       Rainbows::Coolio::DeferredResponse
7   def on_read(data)
8     @client.write("#{data.size.to_s(16)}\r\n")
9     @client.write(data)
10     @client.write("\r\n")
11   end
13   def on_close
14     @client.write("0\r\n\r\n")
15     super
16   end
17 end