Class: Aws::EventStream::Decoder

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
gems/aws-eventstream/lib/aws-eventstream/decoder.rb

Overview

This class provides method for decoding binary inputs into single or multiple messages (Aws::EventStream::Message).

  • #decode - decodes messages from an IO like object responds to #read that containing binary data, returning decoded Aws::EventStream::Message along the way or wrapped in an enumerator

Examples

decoder = Aws::EventStream::Decoder.new

# decoding from IO decoder.decode(io) do |message| message.headers # => { ... } message.payload # => StringIO / Tempfile end

# alternatively message_pool = decoder.decode(io) message_pool.next # => Aws::EventStream::Message

  • #decode_chunk - decodes a single message from a chunk of data, returning message object followed by boolean(indicating eof status of data) in an array object

Examples

# chunk containing exactly one message data message, chunk_eof = decoder.decode_chunk(chunk_str) message # => Aws::EventStream::Message chunk_eof # => true

# chunk containing a partial message message, chunk_eof = decoder.decode_chunk(chunk_str) message # => nil chunk_eof # => true # chunk data is saved at decoder's message_buffer

# chunk containing more that one data message message, chunk_eof = decoder.decode_chunk(chunk_str) message # => Aws::EventStream::Message chunk_eof # => false # extra chunk data is saved at message_buffer of the decoder

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ Decoder

Returns a new instance of Decoder.

Parameters:

  • options (Hash) (defaults to: {}) —

    The initialization options.

Options Hash (options):

  • :format (Boolean) — default: true —

    When false it disables user-friendly formatting for message header values including timestamp and uuid etc.



83
84
85
86
 
# File 'gems/aws-eventstream/lib/aws-eventstream/decoder.rb', line 83

def initialize(options = {})
  @format = options.fetch(:format, true)
  @message_buffer = ''
end

Instance Method Details

#decode(io) {|message| ... } ⇒ Enumerable<Message>?

Decodes messages from a binary stream

Parameters:

  • io (IO#read) —

    An IO-like object that responds to #read

Yield Parameters:

Returns:

  • (Enumerable<Message>, nil) —

    Returns a new Enumerable containing decoded messages if no block is given



96
97
98
99
100
101
102
103
 
# File 'gems/aws-eventstream/lib/aws-eventstream/decoder.rb', line 96

def decode(io, &block)
  raw_message = io.read
  decoded_message = decode_message(raw_message)
  return wrap_as_enumerator(decoded_message) unless block_given?
  # fetch message only
  raw_event, _eof = decoded_message
  block.call(raw_event)
end

#decode_chunk(chunk = nil) ⇒ Array<Message|nil, Boolean>

Decodes a single message from a chunk of string

Parameters:

  • chunk (String) (defaults to: nil) —

    A chunk of string to be decoded, chunk can contain partial event message to multiple event messages When not provided, decode data from #message_buffer

Returns:

  • (Array<Message|nil, Boolean>) —

    Returns single decoded message and boolean pair, the boolean flag indicates whether this chunk has been fully consumed, unused data is tracked at #message_buffer



114
115
116
117
 
# File 'gems/aws-eventstream/lib/aws-eventstream/decoder.rb', line 114

def decode_chunk(chunk = nil)
  @message_buffer = [@message_buffer, chunk].pack('a*a*') if chunk
  decode_message(@message_buffer)
end