Contents

# encoding: UTF-8

require 'em-synchrony'
require 'em-synchrony/connection_pool'

require 'redis'
require 'redis/connection/synchrony'


require File.expand_path("./helper", File.dirname(__FILE__))

PORT    = 6381
OPTIONS = {:port => PORT, :db => 15}

#
# if running under Eventmachine + Synchrony (Ruby 1.9+), then
# we can simulate the blocking API while performing the network
# IO via the EM reactor.
#

EM.synchrony do
  r = Redis.new OPTIONS
  r.flushdb

  r.rpush "foo", "s1"
  r.rpush "foo", "s2"

  assert_equal 2, r.llen("foo")
  assert_equal "s2", r.rpop("foo")

  r.set("foo", "bar")

  assert_equal "bar", r.getset("foo", "baz")
  assert_equal "baz", r.get("foo")

  r.set("foo", "a")

  assert_equal 1, r.getbit("foo", 1)
  assert_equal 1, r.getbit("foo", 2)
  assert_equal 0, r.getbit("foo", 3)
  assert_equal 0, r.getbit("foo", 4)
  assert_equal 0, r.getbit("foo", 5)
  assert_equal 0, r.getbit("foo", 6)
  assert_equal 1, r.getbit("foo", 7)

  r.flushdb

  # command pipelining
  r.pipelined do
    r.lpush "foo", "s1"
    r.lpush "foo", "s2"
  end

  assert_equal 2, r.llen("foo")
  assert_equal "s2", r.lpop("foo")
  assert_equal "s1", r.lpop("foo")

  assert_equal "OK", r.client.call(:quit)
  assert_equal "PONG", r.ping


  rpool = EM::Synchrony::ConnectionPool.new(size: 5) { Redis.new OPTIONS }

  result = rpool.watch 'foo' do |rd|
    assert_kind_of Redis, rd

    rd.set "foo", "s1"
    rd.multi do |multi|
      multi.set "foo", "s2"
    end
  end

  assert_equal nil, result
  assert_equal "s1", rpool.get("foo")

  result = rpool.watch "foo" do |rd|
    assert_kind_of Redis, rd

    rd.multi do |multi|
      multi.set "foo", "s3"
    end
  end

  assert_equal ["OK"], result
  assert_equal "s3", rpool.get("foo")

  EM.stop
end

Version data entries

29 entries across 28 versions & 9 rubygems

Version	Path
finsync_redis-3.3.5	test/synchrony_driver.rb
redis-3.3.5	test/synchrony_driver.rb
logstash-filter-cache-redis-0.3.1	vendor/bundle/jruby/1.9/gems/redis-3.3.3/test/synchrony_driver.rb
logstash-filter-cache-redis-0.3.0	vendor/bundle/jruby/1.9/gems/redis-3.3.3/test/synchrony_driver.rb
logstash-filter-cache-redis-0.2.0	vendor/bundle/jruby/1.9/gems/redis-3.3.3/test/synchrony_driver.rb
logstash-filter-cache-redis-0.1.0	vendor/bundle/jruby/1.9/gems/redis-3.3.3/test/synchrony_driver.rb
enju_leaf-1.2.1	vendor/bundle/ruby/2.3/gems/redis-3.3.3/test/synchrony_driver.rb
redis-3.3.3	test/synchrony_driver.rb
abaci-0.3.0	vendor/bundle/gems/redis-3.3.1/test/synchrony_driver.rb
abaci-0.3.0	vendor/bundle/gems/redis-3.3.2/test/synchrony_driver.rb
redis-3.3.2	test/synchrony_driver.rb
redis-3.3.1	test/synchrony_driver.rb
ish_lib_manager-0.0.1	test/dummy/vendor/bundle/ruby/2.3.0/gems/redis-3.3.0/test/synchrony_driver.rb
redis-3.3.0	test/synchrony_driver.rb
discourse-redis-3.2.2	test/synchrony_driver.rb
redis-3.2.2	test/synchrony_driver.rb
redis-3.2.1	test/synchrony_driver.rb
redis-3.2.0	test/synchrony_driver.rb
redis-3.1.0	test/synchrony_driver.rb
redis-3.0.7	test/synchrony_driver.rb