class Aws::Binary::EventStreamDecoder

def initialize(protocol, rules, output_ref, error_refs, io, event_stream_handler = nil)

Parameters:

event_stream_handler (EventStream|nil) -- A Service EventStream object
error_refs (Array) -- array of ShapeRefs for errors
output_ref (ShapeRef) -- ShapeRef of output shape
rules (ShapeRef) -- ShapeRef of the eventstream member
protocol (String) --

def initialize(protocol, rules, output_ref, error_refs, io, event_stream_handler = nil)
  @decoder = Aws::EventStream::Decoder.new
  @event_parser = EventParser.new(parser_class(protocol), rules, error_refs, output_ref)
  @stream_class = extract_stream_class(rules.shape.struct_class)
  @emitter = event_stream_handler.event_emitter
  @events = []
end

Instance Methods