Contents

require "redis"

class Redic
  def initialize(options = {})
    @client = Redis::Client.new(options)
    @buffer = []
  end

  def call(*args)
    @client.send(:ensure_connected) do
      @client.write(args)
      @client.read
    end
  end

  def write(*args)
    @buffer << args
  end

  def run
    @client.send(:ensure_connected) do
      @buffer.each do |args|
        @client.write(args)
      end

      @buffer.map do
        @client.read
      end
    end
  ensure
    @buffer.clear
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
redic-0.0.2	lib/redic.rb