class RedisClient::PubSub

def next_event(timeout = nil)
  unless raw_connection
    raise ConnectionError, "Connection was closed or lost"
  end
  raw_connection.read(timeout)
rescue ReadTimeoutError
  nil
end