- MPDClient.loop.run_until_complete(future)
- # return once completed.
- return future.result().resp
+ self.futures.append(future)
+ if not self.asio:
+ # return once completed.
+ self.eloop.run_until_complete(future)
+ return future
+ # alternative w/ callback
+ #if not self.asio:
+ # future.add_done_callback(lambda ftr: MPDClient.loop.stop())
+ # self.eloop.run_forever()
+ #return future
+
+ def run(self):
+ if self.futures:
+ self.eloop.run_until_complete(asyncio.gather(*self.futures))
+ self.futures = []
+ else:
+ logging.info('No task found in queue, need to set self.asio?')