Module: Consumer::PositionStore::Build

Defined in:
lib/consumer/position_store.rb

Instance Method Summary collapse

Instance Method Details

#build(stream) ⇒ Object 



59
60
61
62
63
64
65
66
 
# File 'lib/consumer/position_store.rb', line 59

def build(stream)
  stream = EventSource::Stream.canonize stream

  instance = new stream
  ::Telemetry.configure instance
  instance.configure
  instance
end