Sha256: b27eb35b5a2389be4a34db9c657dfd6b7cdac3fc64f29452d657804f8fd31285

Contents?: true

Size: 342 Bytes

Versions: 5

Compression:

Stored size: 342 Bytes

Contents

module Waffle
  class Base

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

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

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

  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
waffle-0.3.3 lib/waffle/base.rb
waffle-0.3.2 lib/waffle/base.rb
waffle-0.3.1 lib/waffle/base.rb
waffle-0.2.2 lib/waffle/base.rb
waffle-0.2.1 lib/waffle/base.rb