Class: Pubsub::Redis::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/pubsub/redis/client.rb

Instance Method Summary collapse

Constructor Details

#initialize(url) ⇒ Client

Returns a new instance of Client.



6
7
8
 
# File 'lib/pubsub/redis/client.rb', line 6

def initialize(url)
  @redis_client = ::Redis.new(url: url)
end

Instance Method Details

#publish(channel, message) ⇒ Object 



10
11
12
 
# File 'lib/pubsub/redis/client.rb', line 10

def publish(channel, message)
  @redis_client.publish(channel, message)
end

#subscribe(channel) ⇒ Object 



14
15
16
17
18
19
20
 
# File 'lib/pubsub/redis/client.rb', line 14

def subscribe(channel)
  @redis_client.subscribe(channel) do |on|
    on.message do |_channel, message|
      yield message
    end
  end
end