class Aws::Rest::Response::Body
Public Class Methods
new(parser_class, rules)
click to toggle source
@param [Class] parser_class @param [Seahorse::Model::ShapeRef] rules
# File lib/aws-sdk-core/rest/response/body.rb, line 12 def initialize(parser_class, rules) @parser_class = parser_class @rules = rules end
Public Instance Methods
apply(body, data)
click to toggle source
@param [IO] body @param [Hash, Struct] data
# File lib/aws-sdk-core/rest/response/body.rb, line 19 def apply(body, data) if event_stream? data[@rules[:payload]] = parse_eventstream(body) elsif streaming? data[@rules[:payload]] = body elsif @rules[:payload] data[@rules[:payload]] = parse(body.read, @rules[:payload_member]) elsif !@rules.shape.member_names.empty? parse(body.read, @rules, data) end end
Private Instance Methods
event_stream?()
click to toggle source
# File lib/aws-sdk-core/rest/response/body.rb, line 33 def event_stream? @rules[:payload] && @rules[:payload_member].eventstream end
parse(body, rules, target = nil)
click to toggle source
# File lib/aws-sdk-core/rest/response/body.rb, line 44 def parse(body, rules, target = nil) @parser_class.new(rules).parse(body, target) if body.size > 0 end
parse_eventstream(body)
click to toggle source
# File lib/aws-sdk-core/rest/response/body.rb, line 48 def parse_eventstream(body) # body contains an array of parsed event when they arrive @rules[:payload_member].shape.struct_class.new do |payload| body.each { |event| payload << event } end end
streaming?()
click to toggle source
# File lib/aws-sdk-core/rest/response/body.rb, line 37 def streaming? @rules[:payload] && ( BlobShape === @rules[:payload_member].shape || StringShape === @rules[:payload_member].shape ) end