code: def stream_log(self, callback, connection_id='monitor'):
          
          conn = self.connection_pool.get_connection(connection_id, None)
          conn.send_command('monitor')
          while callback(conn.read_response()):
              pass
docs: Stream Redis activity one line at a time to the given
          callback.
  
          :param callback: A function that accepts a single argument,
              the Redis command.