Module: EventSource::Read::Call

Defined in:
lib/event_source/read.rb

Instance Method Summary collapse

Instance Method Details

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



34
35
36
37
 
# File 'lib/event_source/read.rb', line 34

def call(stream_name, position: nil, batch_size: nil, precedence: nil, cycle_maximum_milliseconds: nil, cycle_timeout_milliseconds: nil, cycle: nil, session: nil, &action)
  instance = build(stream_name, position: position, batch_size: batch_size, precedence: precedence, cycle_maximum_milliseconds: cycle_maximum_milliseconds, cycle_timeout_milliseconds: cycle_timeout_milliseconds, cycle: cycle, session: session)
  instance.(&action)
end