WebSocket.send_bytes is a coroutine as of aiohttp 3.0 changing transp…

…ort.write to await the coroutine if necessary.

aiogremlin/driver/aiohttp/transport.py

@@ -1,3 +1,4 @@
+import asyncio
 import aiohttp
 
 from gremlin_python.driver import transport
@@ -18,8 +19,10 @@ async def connect(self, url, *, ssl_context=None):
         self._ws = await self._client_session.ws_connect(url)
         self._connected = True
 
-    def write(self, message):
-        self._ws.send_bytes(message)
+    async def write(self, message):
+        corou = self._ws.send_bytes(message)
+        if asyncio.iscoroutine(corou):
+          await corou
 
     async def read(self):
         data = await self._ws.receive()