Merge pull request #6 from tomvanderlee/feature/websocketsv2.1.0main

Added websocket support

1 files changed, 3 insertions, 4 deletions

diff --git a/ttun_server/redis.py b/ttun_server/redis.py
index 3065dec..18fbca2 100644
--- a/ttun_server/redis.py
+++ b/ttun_server/redis.py
@@ -1,6 +1,8 @@
+import asyncio
 import os
+from asyncio import get_running_loop
 
-from aioredis import ConnectionPool, Redis
+from redis.asyncio import ConnectionPool, Redis
 
 
 class RedisConnectionPool:
@@ -9,9 +11,6 @@ class RedisConnectionPool:
     def __init__(self):
        self.pool = ConnectionPool.from_url(os.environ.get('REDIS_URL'))
 
-    def __del__(self):
-        self.pool.disconnect()
-
     @classmethod
     def get_connection(cls) -> Redis:
         if cls.instance is None: