Class: Cosmo::Stream::Message

Inherits:

Object

• Object
• Cosmo::Stream::Message

Extended by:

Forwardable

Defined in:

lib/cosmo/stream/message.rb

Instance Method Summary

• #consumer_sequence ⇒ Object
• #data ⇒ Object
• #initialize(msg, serializer: nil) ⇒ Message constructor

  A new instance of Message.

• #stream_sequence ⇒ Object

Constructor Details

#initialize(msg, serializer: nil) ⇒ Message

Returns a new instance of Message.

# File 'lib/cosmo/stream/message.rb', line 13

def initialize(msg, serializer: nil)
  @msg = msg
  @serializer = serializer || Serializer
end

Instance Method Details

#consumer_sequence ⇒ Object

# File 'lib/cosmo/stream/message.rb', line 26

def consumer_sequence
  metadata.sequence.consumer
end

#data ⇒ Object

# File 'lib/cosmo/stream/message.rb', line 18

def data
  @serializer.deserialize(@msg.data)
end

#stream_sequence ⇒ Object

# File 'lib/cosmo/stream/message.rb', line 22

def stream_sequence
  metadata.sequence.stream
end