class Aws::Stubbing::Protocols::Rest

def encode_eventstream_response(rules, data, builder)
  data.inject('') do |stream, event_data|
    # construct message headers and payload
    opts = {headers: {}}
    case event_data.delete(:message_type)
    when 'event'
      encode_event(opts, rules, event_data, builder)
    when 'error'
      # errors are unmodeled
      encode_error(opts, event_data)
    when 'exception'
      # Pending
      raise 'Stubbing :exception event is not supported'
    end
    [stream, Aws::EventStream::Encoder.new.encode(
      Aws::EventStream::Message.new(opts)
    )].pack('a*a*')
  end
end