Class: Waffle::Base

Inherits:

Object

• Object
• Waffle::Base

Defined in:

lib/waffle/base.rb

Instance Method Summary

• #initialize(transport = nil) ⇒ Base constructor

  A new instance of Base.

• #publish(flow = 'events', message = '') ⇒ Object
• #subscribe(flow = '', &block) ⇒ Object

Constructor Details

#initialize(transport = nil) ⇒ Base

Returns a new instance of Base.

# File 'lib/waffle/base.rb', line 4

def initialize(transport = nil)
  @transport = transport
end

Instance Method Details

#publish(flow = 'events', message = '') ⇒ Object

# File 'lib/waffle/base.rb', line 8

def publish(flow = 'events', message = '')
  @transport.publish flow, message
end

#subscribe(flow = '', &block) ⇒ Object

# File 'lib/waffle/base.rb', line 12

def subscribe(flow = '', &block)
  @transport.subscribe flow, &block
end