Module: Consumer::StreamMacro

Defined in:
lib/consumer/consumer.rb

Instance Method Summary collapse

Instance Method Details

#stream_macro(stream_name) ⇒ Object Also known as: stream 



9
10
11
12
13
14
15
 
# File 'lib/consumer/consumer.rb', line 9

def stream_macro(stream_name)
  stream = EventSource::Stream.new stream_name

  define_method :stream do
    stream
  end
end