Contents

safe_require 'em-hiredis', 'gem install em-hiredis'

##
# Midori Extension for Redis Driver
class Midori::Redis

  # Init a Redis Connection
  # @param [Array] args args EM::Hiredis.connect
  def initialize(*args)
    @connection = EM::Hiredis.connect(*args)
    @connection
  end

  # Call a redis request asynchronously
  # @param [String] sys method name
  # @param [Array] args args of the method calling
  def method_missing(sys, *args)
    await(Promise.new(->(resolve, _reject) {
      @connection.send(sys, *args).callback do |*ret_args|
        resolve.call(*ret_args)
      end
    }))
  end

  # Return raw pubsub mode
  # @return [EM::Hiredis::Pubsub] raw pubsub
  def pubsub
    @connection.pubsub
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
em-midori-0.1.8	lib/midori/extension/redis.rb