Merge branch 'fix-asyncio' into 'master'

Quick hacky fix for asyncio

There may be a reason we weren't creating the `_call_task` in `__init__`, but I'm not sure what it was.

See merge request !6

PyIRC/io/asyncio.py

@@ -49,7 +49,10 @@ class IRCProtocol(IRCBase, asyncio.Protocol):
 
     def __init__(self, *args, **kwargs):
         self._call_queue = asyncio.Queue()
-        self._call_task = None
+
+        # Start the task queue
+        self._call_task = asyncio.async(self._process_queue())
+        self._call_task.add_done_callback(self._process_queue_exit)
 
         super().__init__(*args, **kwargs)
 
@@ -70,10 +73,6 @@ def connect(self):
         :returns:
             An asyncio coroutine representing the connection.
         """
-        # Start the task queue
-        self._call_task = asyncio.async(self._process_queue())
-        self._call_task.add_done_callback(self._process_queue_exit)
-
         loop = asyncio.get_event_loop()
         return loop.create_connection(lambda: self, self.server, self.port,
                                       ssl=self.ssl)
@@ -139,7 +138,6 @@ def _process_queue(self):
 
     def _process_queue_exit(self, future):
         _logger.critical("Process queue died!")
-        self._call_task = None
         self._call_queue = asyncio.Queue()
         self.close()
 
@@ -149,7 +147,7 @@ def call_event(self, hclass, event, *args, **kwargs):
         If no args are passed in, and the signal is in a deferred state, the
         arguments from the last call_event will be used.
         """
-        if self._call_task and self._call_task.exception():
+        if self._call_task.done() and self._call_task.exception():
             # Exception raised, let's get out of here!
             raise self._call_task.exception()