Sha256: 3b563472872dd82003f60dc627fea8677d5e493fe93a4e447498900288b771f2
Contents?: true
Size: 1.37 KB
Versions: 7
Compression:
Stored size: 1.37 KB
Contents
# frozen_string_literal: true
module Aws
module Binary
# @api private
class DecodeHandler < Seahorse::Client::Handler
def call(context)
if eventstream_member = eventstream?(context)
attach_eventstream_listeners(context, eventstream_member)
end
@handler.call(context)
end
private
def eventstream?(ctx)
ctx.operation.output.shape.members.each do |_, ref|
return ref if ref.eventstream
end
end
def attach_eventstream_listeners(context, rules)
context.http_response.on_headers(200) do
protocol = context.config.api.metadata['protocol']
output_handler = context[:output_event_stream_handler] || context[:event_stream_handler]
context.http_response.body = EventStreamDecoder.new(
protocol,
rules,
context.operation.output,
context.operation.errors,
context.http_response.body,
output_handler)
end
context.http_response.on_success(200) do
context.http_response.body = context.http_response.body.events
end
context.http_response.on_error do
# Potential enhancement to made
# since we don't want to track raw bytes in memory
context.http_response.body = StringIO.new
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems