class Rdsck::Async::Redis::Context::Psubscribe

doesn't support psubscribe by default. can you believe it?!

Constants

MESSAGE

Public Instance Methods

listen() click to toggle source
# File lib/nchan_tools/rdsck.rb, line 9
def listen
  while response = @connection.read_response
    return response if response.first == MESSAGE
  end
end
subscribe(channels) click to toggle source
# File lib/nchan_tools/rdsck.rb, line 15
def subscribe(channels)
  @connection.write_request ['PSUBSCRIBE', *channels]
  @connection.flush
end
unsubscribe(channels) click to toggle source
# File lib/nchan_tools/rdsck.rb, line 20
def unsubscribe(channels)
  @connection.write_request ['PUNSUBSCRIBE', *channels]
  @connection.flush
end