Class: RedisCluster::Middlewares

Inherits:
Object
  • Object
show all
Defined in:
lib/redis_cluster/middlewares.rb

Overview

Middlewares is collection for RedisCluster middleware.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Middlewares

Returns a new instance of Middlewares.



9
10
11
 
# File 'lib/redis_cluster/middlewares.rb', line 9

def initialize
  @middlewares = Hash.new{ |h, k| h[k] = [] }
end

Instance Attribute Details

#middlewares ⇒ Object (readonly)

Returns the value of attribute middlewares.



7
8
9
 
# File 'lib/redis_cluster/middlewares.rb', line 7

def middlewares
  @middlewares
end

Instance Method Details

#invoke(name, *args, &block) ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/redis_cluster/middlewares.rb', line 19

def invoke(name, *args, &block)
  callback = middlewares[name].reduce(block) do |acc, obs|
    proc{ obs.call(*args, &acc) }
  end

  callback.call
end

#register(name, callable = nil, &block) ⇒ Object 



13
14
15
16
17
 
# File 'lib/redis_cluster/middlewares.rb', line 13

def register(name, callable = nil, &block)
  return if !callable && !block_given?

  middlewares[name] << (callable || block)
end