Sha256: ab663020c13bf2adee81dd6c34c29320f39a3c4001a36c66ec706efa894ecf7e
Contents?: true
Size: 511 Bytes
Versions: 8
Compression:
Stored size: 511 Bytes
Contents
# -*- 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("#{data.size.to_s(16)}\r\n")
@client.write(data)
@client.write("\r\n")
rescue Errno::EINTR
rescue Errno::EAGAIN
return
rescue EOFError
detach
return
end while true
end
end
Version data entries
8 entries across 8 versions & 1 rubygems