Estava tentando fazer um proxy reverso usando WEBrick quando descobri que a versão que eu tinha instalado do WEBrick não continha os métodos necessários para fazer uma leitura "chunked" digna. Então apliquei o seguinte monkey patch:
class WEBrick::HTTPRequest
##
# Prepares the HTTPRequest object for use as the
# source for IO.copy_stream
def body_reader
@body_tmp = []
@body_rd = Fiber.new do
body do |buf|
@body_tmp << buf
Fiber.yield
end
end
@body_rd.resume # grab the first chunk and yield
self
end
# for IO.copy_stream. Note: we may return a larger string than +size+
# here; but IO.copy_stream does not care.
def readpartial(size, buf = ''.b) # :nodoc
res = @body_tmp.shift or raise EOFError, 'end of file reached'
buf.replace(res)
res.clear
@body_rd.resume # get more chunks
buf
end
end
Vi que ele usa Fiber
para fazer a leitura em chunks, mas não entendi o que a classe Fiber
é, nem o que o Fiber.yield
tem de diferente de um simples yield
.
Esse Fiber
tem alguma finalidade com threads
? O seu grande ganho é em usá-lo com yield
s, ou tem algum outro caso de uso que não seja esse?