Contents

module Scales
  module PubSub
    module Async
      class << self
        
        def publish(channel, message)
          Storage::Async.publish(channel, message)
        end
        
        def subscribe(channel)
          out = Storage::Async.subscribe(channel)
          Storage::Async.connection.del(channel)
          out
        end
        
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
scales-core-0.0.1.beta.2	lib/scales-core/pub_sub/async.rb
scales-core-0.0.1.beta.1	lib/scales-core/pub_sub/async.rb