Module: Sourced::Consumer

Included in:
Decider, Projector
Defined in:
lib/sourced/consumer.rb

Defined Under Namespace

Classes: ConsumerInfo

Instance Method Summary collapse

Instance Method Details

#consumer {|info| ... } ⇒ Object

Yields:

  • (info)

Raises:

  • (Plumb::ParseError) 


32
33
34
35
36
37
38
39
40
 
# File 'lib/sourced/consumer.rb', line 32

def consumer(&)
  return consumer_info unless block_given?

  info = ConsumerInfo.new(group_id: name)
  yield info
  raise Plumb::ParseError, info.errors unless info.valid?

  @consumer_info = info
end

#consumer_info ⇒ Object 



28
29
30
 
# File 'lib/sourced/consumer.rb', line 28

def consumer_info
  @consumer_info ||= ConsumerInfo.new(group_id: name, start_from: :beginning)
end