class Aws::Plugins::StubResponses::Handler

def call(context)
  stub = context.client.next_stub(context)
  resp = Seahorse::Client::Response.new(context: context)
  async_mode = context.client.is_a? Seahorse::Client::AsyncBase
  apply_stub(stub, resp, async_mode)
  async_mode ? Seahorse::Client::AsyncResponse.new(
    context: context, stream: context[:input_event_stream_handler].event_emitter.stream, sync_queue: Queue.new) : resp
end