class Aws::Binary::EventStreamEncoder

@api private

Attributes

prior_signature[RW]
rules[R]

Public Class Methods

new(protocol, rules, input_ref, signer) click to toggle source

@param [String] protocol @param [ShapeRef] rules ShapeRef of the eventstream member @param [ShapeRef] input_ref ShapeRef of the input shape @param [Aws::Sigv4::Signer] signer

# File lib/aws-sdk-core/binary/event_stream_encoder.rb, line 14
def initialize(protocol, rules, input_ref, signer)
  @encoder = Aws::EventStream::Encoder.new
  @event_builder = EventBuilder.new(serializer_class(protocol), rules)
  @input_ref = input_ref
  @rules = rules
  @signer = signer
  @prior_signature = nil
end

Public Instance Methods

encode(event_type, params) click to toggle source
# File lib/aws-sdk-core/binary/event_stream_encoder.rb, line 27
def encode(event_type, params)
  if event_type == :end_stream
    payload = ''
  else
    payload = @encoder.encode(@event_builder.apply(event_type, params))
  end
  headers, signature = @signer.sign_event(@prior_signature, payload, @encoder)
  @prior_signature = signature
  message = Aws::EventStream::Message.new(
    headers: headers,
    payload: StringIO.new(payload)
  )
  @encoder.encode(message)
end

Private Instance Methods

serializer_class(protocol) click to toggle source
# File lib/aws-sdk-core/binary/event_stream_encoder.rb, line 44
def serializer_class(protocol)
  case protocol
  when 'rest-xml' then Aws::Xml::Builder
  when 'rest-json' then Aws::Json::Builder
  when 'json' then Aws::Json::Builder
  when 'smithy-rpc-v2-cbor' then Aws::RpcV2::Builder
  else raise "unsupported protocol #{protocol} for event stream"
  end
end