Module: EventSource::Read::Configure

Defined in:
lib/event_source/read.rb

Instance Method Summary collapse

Instance Method Details

#configure(receiver, stream_name, attr_name: nil, position: nil, batch_size: nil, session: nil) ⇒ Object


39
40
41
42
43
# File 'lib/event_source/read.rb', line 39

def configure(receiver, stream_name, attr_name: nil, position: nil, batch_size: nil, session: nil)
  attr_name ||= :read
  instance = build(stream_name, position: position, batch_size: batch_size, session: session)
  receiver.public_send "#{attr_name}=", instance
end