3 from util import go_utils
7 _moduleLogger = logging.getLogger(__name__)
10 class AudioIndex(object):
13 self._backend = backend.Backend()
14 self._indexing = go_utils.AsyncPool()
17 self._indexing.start()
22 def download(self, func, on_success, on_error, *args, **kwds):
23 self._indexing.clear_tasks()
24 self._indexing.add_task(
25 getattr(self._backend, func),