Fix errors

README.md

@@ -6,6 +6,28 @@ An asynchronous client library for [신경](https://github.com/queer/singyeong),
 
 If 신경 is alpha quality software, then Singyeong.py is pre-alpha quality software. Expect things to break spectacularly.
 
+## Installing
+You can get the library directly from PyPI:
+```shell
+python3 -m pip install -U singyeong.py
+```
+If you are using Windows, then the following should be used instead:
+```shell
+py -3 -m pip install -U singyeong.py
+```
+### Install with faster json support
+
+```shell
+pip install singyeong.py[ujson]
+```
+
+### Install with msgpack support
+
+```shell
+pip install singyeong.py[msgpack]
+```
+
+
 ## Event Reference
 This section outlines the different types of events listened by Client.
 
@@ -236,3 +258,7 @@ stdout of your program.
 For more information, check the documentation and tutorial of the
 [logging](https://docs.python.org/3/library/logging.html) module.
 
+# To-Do
+ - Metadata support :)
+ - Queues
+ - Unit tests

singyeong/__init__.py

@@ -2,7 +2,7 @@
 __author__ = 'StartIT'
 __license__ = 'MIT'
 __copyright__ = 'Copyright (c) 2021 StartIT'
-__version__ = '1.0.1a'
+__version__ = '1.0.1'
 
 __path__ = __import__('pkgutil').extend_path(__path__, __name__)
 

singyeong/utils.py

@@ -12,10 +12,10 @@ async def maybe_coroutine(f, *args, **kwargs):
         return value
 
 
-def create_task(f, *args, **kwargs) -> None:
+def create_task(loop, f, *args, **kwargs) -> None:
     value = f(*args, **kwargs)
     if _isawaitable(value):
-        asyncio.create_task(value)
+        loop.create_task(value)
 
 
 def with_type(value):

singyeong/websocket.py

@@ -114,7 +114,7 @@ async def poll_event(self):
                 return
 
             if op == OpCode.READY:
-                create_task(self.on_ready)
+                create_task(self.loop, self.on_ready)
                 return
 
             if op == OpCode.HEARTBEAT_ACK:
@@ -128,13 +128,14 @@ async def poll_event(self):
         except AssertionError:
             pass
         except Exception as ex:
-            create_task(self.on_error, ex)
+            create_task(self.loop, self.on_error, ex)
 
     def handle_dispatch(self, data):
         if data['t'] in ("SEND", "BROADCAST"):
             payload = data['d']
 
             create_task(
+                self.loop,
                 self.on_message,
                 Message(
                     nonce=payload.get('nonce'),