omitted a variable from connection.py

README.md

@@ -0,0 +1,35 @@
+A custom made event loop with async and await syntax,
+background tasks, and custom functions, along with concurrent synchronization.
+
+The selectors module makes this all possible.
+
+https://docs.python.org/3/library/selectors.html
+
+![Screenshot 2024-06-21 125920](https://github.com/bendeez/async_event_loop/assets/127566471/378260f9-9145-49ff-b910-366f1204171f)
+
+```python
+from event_loop import EventLoop
+from connection import Connection
+
+
+
+loop = EventLoop(max_connections=15)
+
+async def scrape_other_website():
+    results = await loop.gather(Connection("https://www.google.com/"))
+    return results
+
+async def scrape_website(url):
+    first_result = await scrape_other_website()
+    print(first_result)
+    second_result = await loop.gather(*[Connection(url) for _ in range(10)])
+    return second_result
+
+async def main(loop):
+    url = "https://github.com/"
+    task_1 = loop.create_task(scrape_website(url))
+    result = await loop.gather(task_1)
+    print(result)
+
+loop.run(main(loop))
+

connection.py

@@ -17,8 +17,7 @@ def initialize_connection(self):
         self.get_url_details()
         s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
         if self.port == 443:
-            context = ssl.create_default_context()
-            self.client = context.wrap_socket(s, server_hostname=self.host)
+            self.client = ssl.create_default_context().wrap_socket(s, server_hostname=self.host)
             self.client.setblocking(False)
         else:
             self.client = s

event_loop.py

@@ -82,8 +82,7 @@ def add_connection(self, connection, fut=None,in_gather=False):
         connection.initialize_connection()
         if len(self.select_connections) < self.max_connections:
             self.select_connections.append(connection)
-            self.select.register(connection.client, selectors.EVENT_READ | selectors.EVENT_WRITE,
-                                 data=connection)
+            self.select.register(connection.client, selectors.EVENT_READ | selectors.EVENT_WRITE, data=connection)
         else:
             # limits the amount of concurrent connections
             self.connection_queue.put(connection)