Module: EventMachine::Protocols::Redis

Defined in:
lib/em-synchrony/em-redis.rb

Constant Summary collapse

SYNC = 
['add', 'auth']

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#connected ⇒ Object (readonly)

Returns the value of attribute connected.



10
11
12
 
# File 'lib/em-synchrony/em-redis.rb', line 10

def connected
  @connected
end

Class Method Details

.aconnect ⇒ Object 



13
 
# File 'lib/em-synchrony/em-redis.rb', line 13

alias :aconnect :connect

.connect(*args) ⇒ Object 



16
17
18
19
20
21
22
23
 
# File 'lib/em-synchrony/em-redis.rb', line 16

def self.connect(*args)
  f = Fiber.current

  conn = self.aconnect(*args)
  conn.callback { f.resume(conn) }

  Fiber.yield
end

Instance Method Details

#amapped_mget(*keys) ⇒ Object

adapted from em-redis’ implementation to use the asynchronous version of mget



48
49
50
51
52
53
54
55
56
57
 
# File 'lib/em-synchrony/em-redis.rb', line 48

def amapped_mget(*keys)
  self.amget(*keys) do |response|
    result = {}
    response.each do |value|
      key = keys.shift
      result.merge!(key => value) unless value.nil?
    end
    yield result if block_given?
  end
end

#call_command(argv, &blk) ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/em-synchrony/em-redis.rb', line 28

def call_command(argv, &blk)
  # async commands are 'a' prefixed
  if (argv.first[0] == 'a') && !SYNC.include?(argv.first.to_s)
    argv[0] = argv[0].to_s.slice(1,argv[0].size)
    old_call_command(argv, &blk)

  else
    # wrap response blocks into fiber callbacks
    # to emulate the sync api
    f = Fiber.current
    blk = proc { |v| v } if !block_given?
    clb = proc { |v| f.resume(blk.call(v)) }

    old_call_command(argv, &clb)
    Fiber.yield
  end
end

#mapped_mget(*keys) ⇒ Object 



59
60
61
62
63
64
65
66
67
 
# File 'lib/em-synchrony/em-redis.rb', line 59

def mapped_mget(*keys)
  f = Fiber.current

  self.amapped_mget(*keys) do |values|
    f.resume(values)
  end

  Fiber.yield
end

#old_call_command ⇒ Object 



25
 
# File 'lib/em-synchrony/em-redis.rb', line 25

alias :old_call_command :call_command