Class: Downstream

Inherits:
Object
  • Object
show all
Defined in:
lib/s3_streamer/client/downstream.rb

Instance Method Summary collapse

Constructor Details

#initialize(uri) ⇒ Downstream

Returns a new instance of Downstream.



5
6
7
 
# File 'lib/s3_streamer/client/downstream.rb', line 5

def initialize(uri)
  @uri = uri
end

Instance Method Details

#each ⇒ Object 



9
10
11
12
13
14
15
16
17
 
# File 'lib/s3_streamer/client/downstream.rb', line 9

def each
  Net::HTTP.start(@uri.host) do |http|
    http.request(Net::HTTP::Get.new @uri) do |response|
      ChunkBuffer.new(response).each do |chunk|
        yield chunk
      end
    end
  end
end