Module: EventMachine::Protocols::Redis
- Defined in:
- lib/em-synchrony/em-redis.rb
Constant Summary collapse
- SYNC =
['add', 'auth']
Instance Attribute Summary collapse
-
#connected ⇒ Object
readonly
Returns the value of attribute connected.
Class Method Summary collapse
Instance Method Summary collapse
-
#amapped_mget(*keys) ⇒ Object
adapted from em-redis’ implementation to use the asynchronous version of mget.
- #call_command(argv, &blk) ⇒ Object
- #mapped_mget(*keys) ⇒ Object
- #old_call_command ⇒ Object
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 |