Module: EventSource::Read::Build

Defined in:
lib/event_source/read.rb

Instance Method Summary collapse

Instance Method Details

#build(stream_name, position: nil, batch_size: nil, precedence: nil, cycle_maximum_milliseconds: nil, cycle_timeout_milliseconds: nil, cycle: nil, session: nil) ⇒ Object 



23
24
25
26
27
28
29
30
 
# File 'lib/event_source/read.rb', line 23

def build(stream_name, position: nil, batch_size: nil, precedence: nil, cycle_maximum_milliseconds: nil, cycle_timeout_milliseconds: nil, cycle: nil, session: nil)
  cycle ||= Cycle.build(maximum_milliseconds: cycle_maximum_milliseconds, timeout_milliseconds: cycle_timeout_milliseconds)

  new(stream_name).tap do |instance|
    instance.configure(batch_size: batch_size, precedence: precedence, session: session)
    Iterator.configure instance, instance.get, stream_name, position: position, cycle: cycle
  end
end