Class: Strobe::Middleware::Proxy::ProxyRequest::DeferrableBody

Inherits:
Object
  • Object
show all
Includes:
EM::Deferrable
Defined in:
lib/strobe/middleware/proxy.rb

Instance Method Summary collapse

Constructor Details

#initialize(request) ⇒ DeferrableBody

Returns a new instance of DeferrableBody.


139
140
141
# File 'lib/strobe/middleware/proxy.rb', line 139

def initialize(request)
  @request = request
end

Instance Method Details

#call(body) ⇒ Object


143
144
145
146
147
148
# File 'lib/strobe/middleware/proxy.rb', line 143

def call(body)
  Array(body).each do |chunk|
    chunk = prepare_chunk(chunk)
    @callback.call(chunk)
  end
end

#each(&blk) ⇒ Object


160
161
162
# File 'lib/strobe/middleware/proxy.rb', line 160

def each(&blk)
  @callback = blk
end

#prepare_chunk(chunk) ⇒ Object


150
151
152
153
154
155
156
157
158
# File 'lib/strobe/middleware/proxy.rb', line 150

def prepare_chunk(chunk)
  if @request.chunked_response_body?
    size = chunk.respond_to?(:bytesize) ? chunk.bytesize : chunk.length
    "#{size.to_s(16)}\r\n#{chunk}\r\n"
  else
    # Thin doesn't like null bodies
    chunk || ''
  end
end