Contents

# encoding: UTF-8

require 'em-synchrony'

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

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

#
# 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
  r.flushdb

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

  assert 2 == r.llen("foo")
  assert "s2" == r.rpop("foo")

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

  assert "bar" == r.getset("foo", "baz")
  assert "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 2 == r.llen("foo")
  assert "s2" == r.lpop("foo")
  assert "s1" == r.lpop("foo")

  assert "OK" == r.client.call(:quit)
  assert "PONG" == r.ping

  EM.stop
end

Version data entries

55 entries across 55 versions & 7 rubygems

Version	Path
classiccms-0.3.5	vendor/bundle/gems/redis-2.2.2/test/synchrony_driver.rb
classiccms-0.3.4	vendor/bundle/gems/redis-2.2.2/test/synchrony_driver.rb
classiccms-0.3.3	vendor/bundle/gems/redis-2.2.2/test/synchrony_driver.rb
classiccms-0.3.2	vendor/bundle/gems/redis-2.2.2/test/synchrony_driver.rb
classiccms-0.3.1	vendor/bundle/gems/redis-2.2.2/test/synchrony_driver.rb
classiccms-0.3.0	vendor/bundle/gems/redis-2.2.2/test/synchrony_driver.rb
resque-pool-0.3.0	vendor/bundle/ruby/1.8/gems/redis-2.2.2/test/synchrony_driver.rb
gorsuch-redis-3.0.0.rc1	test/synchrony_driver.rb
resque-pool-0.3.0.beta.2	vendor/bundle/ruby/1.8/gems/redis-2.2.2/test/synchrony_driver.rb
redis-3.0.0.rc1	test/synchrony_driver.rb
yam-redis-with-retries-2.2.2.1	test/synchrony_driver.rb
vanity-1.7.1	vendor/ruby/1.9.1/gems/redis-2.2.2/test/synchrony_driver.rb
redis-2.2.2	test/synchrony_driver.rb
redis-2.2.1	test/synchrony_driver.rb
redis-2.2.0	test/synchrony_driver.rb