class Rack::App::RequestStream

Public Class Methods

new(io, parser) click to toggle source
# File lib/rack/app/request_stream.rb, line 5
def initialize(io, parser)
  @io = io
  @parser = parser
end

Public Instance Methods

each(&block) click to toggle source
# File lib/rack/app/request_stream.rb, line 10
def each(&block)
  enum = Enumerator.new do |y|
    @io.rewind
    while chunk = @io.gets
      y << @parser.call(chunk)
    end
  end

  block_given? ? enum.each(&block) : enum
end