Class: Async::Redis::Context::Subscribe

Inherits:
Nested
  • Object
show all
Defined in:
lib/async/redis/context/subscribe.rb

Instance Method Summary collapse

Methods inherited from Nested

#call, #close

Constructor Details

#initialize(pool, channels) ⇒ Subscribe

Returns a new instance of Subscribe.



30
31
32
33
34
35
36
 
# File 'lib/async/redis/context/subscribe.rb', line 30

def initialize(pool, channels)
  super(pool)
  
  @channels = channels
  
  subscribe(channels)
end

Instance Method Details

#listen ⇒ Object 



38
39
40
 
# File 'lib/async/redis/context/subscribe.rb', line 38

def listen
  return @connection.read_response
end