in lib/elastic/transport/transport/base.rb [396:416]
def compress_request(body, headers)
if body
headers ||= {}
if gzipped?(body)
headers[CONTENT_ENCODING] = GZIP
elsif use_compression?
headers[CONTENT_ENCODING] = GZIP
gzip = Zlib::GzipWriter.new(StringIO.new)
gzip << body
body = gzip.close.string
else
headers.delete(CONTENT_ENCODING)
end
elsif headers
headers.delete(CONTENT_ENCODING)
end
[body, headers]
end